chaintool/chainqueue
4
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Implement upcoming query on store

Browse Source
This commit is contained in:
lash 2022-03-13 15:45:48 +00:00
parent a6e48d93a8
commit 04dfb185ce
Signed by: lash
GPG Key ID: 21D2E7BB88C2A746
2 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
chainqueue/store/base.py
View File

@ -95,3 +95,8 @@ class Store:
entry.retry() entry.retry()
except StateTransitionInvalid: except StateTransitionInvalid:
entry.readysend() entry.readysend()
def fail(self, k):
entry = QueueEntry(self, k)
entry.reject()

9
tests/test_integrate.py
View File

@ -43,7 +43,7 @@ class TestIntegrateBase(TestShepBase):
self.store.put(b'foo'.hex(), b'bar'.hex(), cache_adapter=MockCacheTokenTx) self.store.put(b'foo'.hex(), b'bar'.hex(), cache_adapter=MockCacheTokenTx)
def test_state_move(self): def test_state_enqueu(self):
hx = b'foo'.hex() hx = b'foo'.hex()
self.store.put(hx, b'bar'.hex(), cache_adapter=MockCacheTokenTx) self.store.put(hx, b'bar'.hex(), cache_adapter=MockCacheTokenTx)
self.store.get(hx) self.store.get(hx)
@ -53,5 +53,12 @@ class TestIntegrateBase(TestShepBase):
self.assertEqual(v[0], hx) self.assertEqual(v[0], hx)
def test_state_defer(self):
hx = b'foo'.hex()
self.store.put(hx, b'bar'.hex(), cache_adapter=MockCacheTokenTx)
self.store.get(hx)
self.store.fail(hx)
if __name__ == '__main__': if __name__ == '__main__':
unittest.main() unittest.main()