diff --git a/chaind/eth/runnable/queuer.py b/chaind/eth/runnable/queuer.py index cb3bcae..d464990 100644 --- a/chaind/eth/runnable/queuer.py +++ b/chaind/eth/runnable/queuer.py @@ -70,20 +70,12 @@ logg.debug('settings:\n{}'.format(settings)) def process_outgoing(chain_spec, adapter, rpc, limit=50): adapter = None process_err = None - for i in range(2): - try: - adapter = ChaindFsAdapter( - settings.get('CHAIN_SPEC'), - settings.dir_for('queue'), - EthCacheTx, - dispatcher, - ) - except BackendIntegrityError as e: - process_err = e - continue - - if adapter == None: - raise BackendIntegrityError(process_err) + adapter = ChaindFsAdapter( + settings.get('CHAIN_SPEC'), + settings.dir_for('queue'), + EthCacheTx, + dispatcher, + ) upcoming = adapter.upcoming(limit=limit) logg.info('processor has {} candidates for {}, processing with limit {} adapter {} rpc {}'.format(len(upcoming), chain_spec, limit, adapter, rpc)) diff --git a/requirements.txt b/requirements.txt index ed15ce5..2bfdc5c 100644 --- a/requirements.txt +++ b/requirements.txt @@ -1,4 +1,4 @@ -chaind~=0.2.0 +chaind~=0.2.2 hexathon~=0.1.5 chainlib-eth~=0.1.1 pyxdg~=0.27 diff --git a/setup.cfg b/setup.cfg index 4a6ac63..96f8128 100644 --- a/setup.cfg +++ b/setup.cfg @@ -1,6 +1,6 @@ [metadata] name = chaind-eth -version = 0.2.0 +version = 0.2.1 description = Queue server for ethereum author = Louis Holbrook author_email = dev@holbrook.no diff --git a/tests/test_tx.py b/tests/test_tx.py index 20beb65..5cc6635 100644 --- a/tests/test_tx.py +++ b/tests/test_tx.py @@ -11,7 +11,7 @@ from chainlib.chain import ChainSpec from chainqueue.cache import CacheTokenTx from chainlib.error import RPCException from chainlib.status import Status as TxStatus -from chaind.unittest.common import TestChaindFsBase +from chaind.unittest.fs import TestChaindFsBase from chaind.driver import QueueDriver from chaind.filter import StateFilter from chainlib.eth.gas import Gas