Rehabilitate sync driver on changes target handling

This commit is contained in:
lash 2022-03-19 01:58:13 +00:00
parent 36a8609cb5
commit 80f9a8be88
Signed by: lash
GPG Key ID: 21D2E7BB88C2A746

View File

@ -76,10 +76,11 @@ class SyncFsItem:
def next(self, advance_block=False): def next(self, advance_block=False):
v = self.sync_state.get(self.state_key) v = self.sync_state.state(self.state_key)
if v == self.sync_state.DONE: if v == self.sync_state.DONE:
raise SyncDone(self.target) raise SyncDone(self.target)
v = self.sync_state.get(self.state_key)
(block_number, tx_index, target) = sync_state_deserialize(v) (block_number, tx_index, target) = sync_state_deserialize(v)
if advance_block: if advance_block:
block_number += 1 block_number += 1