dexorder/backend
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

finaldata bugfix

Browse Source
This commit is contained in:
Tim
2024-04-04 01:55:01 -04:00
parent aa10e8d48c
commit bc6f4e3023
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/dexorder/walker.py
View File

@@ -77,10 +77,11 @@ class BlockWalker (BlockProgressor):
promo_height = promotion_height(chain, latest.height) promo_height = promotion_height(chain, latest.height)
while (processed_height < promo_height and while (processed_height < promo_height and
(config.walker_stop is None or processed_height < config.walker_stop)): (config.walker_stop is None or processed_height < config.walker_stop)):
cur_height = min(promo_height, processed_height+batch_size-1) start = processed_height + 1
cur_height = min(promo_height, processed_height+batch_size)
if config.walker_stop is not None: if config.walker_stop is not None:
cur_height = min(cur_height, config.walker_stop) cur_height = min(cur_height, config.walker_stop)
await self.handle(processed_height+1, cur_height, chain=chain, w3=w3) await self.handle(start, cur_height, chain=chain, w3=w3)
if self.flush_delay is None or \ if self.flush_delay is None or \
self.flush_type=='blocks' and last_flush + self.flush_delay <= processed_height or \ self.flush_type=='blocks' and last_flush + self.flush_delay <= processed_height or \
self.flush_type=='time' and last_flush + self.flush_delay <= now(): self.flush_type=='time' and last_flush + self.flush_delay <= now():