Compare commits
5 Commits
v0.2.9
...
dev-0.2.11
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5d70550e8b | ||
|
|
dd1879bb91
|
||
|
|
e264ed5c37
|
||
|
|
d472bd4f7c
|
||
|
|
465d692956
|
@@ -1,3 +1,7 @@
|
||||
- 0.2.11
|
||||
* Upgrade shep to handle exception in filestore list
|
||||
- 0.2.10
|
||||
* Upgrade shep to guarantee state lock atomicity
|
||||
- 0.2.9
|
||||
* Minimize instantiations of adapters in filter execution
|
||||
- 0.2.8
|
||||
|
||||
@@ -76,7 +76,6 @@ class StateFilter(SyncFilter):
|
||||
break
|
||||
except NotLocalTxError:
|
||||
logg.debug('skipping not local transaction {}'.format(tx.hash))
|
||||
self.__stop_adapter()
|
||||
return False
|
||||
except BackendError as e:
|
||||
logg.error('adapter get failed: {}, one more try'.format(e))
|
||||
|
||||
@@ -39,3 +39,9 @@ class MockTx:
|
||||
def __init__(self, tx_hash, status=TxStatus.SUCCESS):
|
||||
self.hash = tx_hash
|
||||
self.status = status
|
||||
|
||||
|
||||
class MockBlock:
|
||||
|
||||
def __init__(self, number):
|
||||
self.number = number
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
chainlib~=0.1.2
|
||||
chainqueue~=0.1.12
|
||||
chainsyncer~=0.4.4
|
||||
chainqueue~=0.1.15
|
||||
chainsyncer~=0.4.7
|
||||
confini~=0.6.0
|
||||
funga~=0.5.2
|
||||
pyxdg~=0.26
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
[metadata]
|
||||
name = chaind
|
||||
version = 0.2.9
|
||||
version = 0.2.11
|
||||
description = Base package for chain queue service
|
||||
author = Louis Holbrook
|
||||
author_email = dev@holbrook.no
|
||||
|
||||
@@ -14,6 +14,7 @@ from chaind.filter import StateFilter
|
||||
# test imports
|
||||
from chaind.unittest.common import (
|
||||
MockTx,
|
||||
MockBlock,
|
||||
MockCacheAdapter,
|
||||
MockDispatcher,
|
||||
)
|
||||
@@ -76,7 +77,8 @@ class TestChaindFs(TestChaindFsBase):
|
||||
|
||||
fltr = StateFilter(self.chain_spec, self.path, MockCacheAdapter)
|
||||
tx = MockTx(hsh)
|
||||
fltr.filter(None, None, tx)
|
||||
block = MockBlock(42)
|
||||
fltr.filter(None, block, tx)
|
||||
|
||||
|
||||
def test_fs_filter_fail(self):
|
||||
@@ -87,7 +89,8 @@ class TestChaindFs(TestChaindFsBase):
|
||||
|
||||
fltr = StateFilter(self.chain_spec, self.path, MockCacheAdapter)
|
||||
tx = MockTx(hsh, TxStatus.ERROR)
|
||||
fltr.filter(None, None, tx)
|
||||
block = MockBlock(42)
|
||||
fltr.filter(None, block, tx)
|
||||
|
||||
|
||||
def test_upcoming(self):
|
||||
|
||||
Reference in New Issue
Block a user