From 6fb903d37bdf3615cac7a9525b0c60d81d738ce9 Mon Sep 17 00:00:00 2001 From: William Luke Date: Thu, 2 Dec 2021 16:36:19 +0300 Subject: [PATCH] revert back to `celery.chain` --- apps/cic-eth/cic_eth/api/api_task.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/apps/cic-eth/cic_eth/api/api_task.py b/apps/cic-eth/cic_eth/api/api_task.py index cce9caa7..79078bda 100644 --- a/apps/cic-eth/cic_eth/api/api_task.py +++ b/apps/cic-eth/cic_eth/api/api_task.py @@ -434,7 +434,7 @@ class Api(ApiBase): :param address: Ethereum address of holder :type address: str, 0x-hex - :param token_symbol: ERC20 token symbol of tokens to send + :param token_symbol: ERC20 token symbol of token to send :type token_symbol: str :param include_pending: If set, will include transactions that have not yet been fully processed :type include_pending: bool @@ -488,9 +488,9 @@ class Api(ApiBase): s_balance_incoming.link(s_balance_outgoing) last_in_chain = s_balance_outgoing - one = s_tokens | s_balance - two = s_tokens | s_balance_incoming - three = s_tokens | s_balance_outgoing + one = celery.chain(s_tokens, s_balance) + two = celery.chain(s_tokens, s_balance_incoming) + three = celery.chain(s_tokens, s_balance_outgoing) t = None if self.callback_param != None: @@ -500,7 +500,7 @@ class Api(ApiBase): t = celery.chord([one, two, three])(s_result) else: # TODO: Chord is inefficient with only one chain, but assemble_balances must be able to handle different structures in order to avoid chord - one = s_tokens | s_balance + one = celery.chain(s_tokens, s_balance) if self.callback_param != None: s_result.link(self.callback_success).on_error(self.callback_error) t = celery.chord([one])(s_result)