From 9cd89f4a836822ac54f9b2c9b55a0fa8c49e9da4 Mon Sep 17 00:00:00 2001 From: lash Date: Sun, 10 Apr 2022 16:45:58 +0000 Subject: [PATCH] Handle duplicate tx exception --- chaind/eth/runnable/tasker.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/chaind/eth/runnable/tasker.py b/chaind/eth/runnable/tasker.py index f40a5f4..f93bdba 100644 --- a/chaind/eth/runnable/tasker.py +++ b/chaind/eth/runnable/tasker.py @@ -17,6 +17,7 @@ from chainqueue import ( Store, Status, ) +from chainqueue.error import DuplicateTxError from chainqueue.store.fs import ( IndexStore, CounterStore, @@ -118,6 +119,7 @@ def main(): tx_hash = queue_adapter.put(r.hex()) except DuplicateTxError as e: logg.error('tx already exists as {}'.format(e)) + continue except ValueError as e: logg.error('adapter rejected input {}: "{}"'.format(r.hex(), e)) continue