Avoid duplicate txs, start store before sync

chaind/eth/runnable/syncer.py

@@ -105,6 +105,7 @@ def main():
     fltr = StateFilter(queue_adapter)
     sync_store = SyncFsStore(config.get('SESSION_RUNTIME_DIR'), session_id=config.get('SESSION_ID'))
     sync_store.register(fltr)
+    sync_store.start()
 
     chain_interface = EthChainInterface()
     drv = ChainInterfaceDriver(sync_store, chain_interface, offset=session_block_offset, target=block_limit)

chaind/eth/runnable/tasker.py

@@ -116,7 +116,9 @@ def main():
 
         try:
             tx_hash = queue_adapter.put(r.hex())
-        except Exception as e:
+        except DuplicateTxError as e:
+            logg.error('tx already exists as {}'.format(e))
+        except ValueError as e:
             logg.error('adapter rejected input {}: "{}"'.format(r.hex(), e))
             continue