Implement chainlib cli for traffic script

2021-08-25 09:33:23 +00:00
parent f0b4c42c68
commit 3bf92e7a8a
9 changed files with 57 additions and 45 deletions
--- a/apps/cic-eth/cic_eth/runnable/daemons/dispatcher.py
+++ b/apps/cic-eth/cic_eth/runnable/daemons/dispatcher.py
@@ -101,14 +101,14 @@ class DispatchSyncer:
                    LockEnum.QUEUE,
                    tx['from'],
                    ],
-                queue=queue,
+                queue=config.get('CELERY_QUEUE'),
                )
            s_send = celery.signature(
                    'cic_eth.eth.tx.send',
                    [
                        self.chain_spec.asdict(),
                        ], 
-                    queue=queue,
+                    queue=config.get('CELERY_QUEUE'),
                    )
            s_check.link(s_send)
            t = s_check.apply_async()