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

runner worker error reports

Browse Source
This commit is contained in:
Tim Olson
2023-12-28 21:40:52 -04:00
parent 8a9813baed
commit 52cb2f8ad0
1 changed files with 28 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
src/dexorder/runner.py
View File

@@ -174,30 +174,35 @@ class BlockStateRunner:
async def worker(self): async def worker(self):
log.debug(f'runner worker started') try:
w3 = current_w3.get() log.debug(f'runner worker started')
chain = current_chain.get() w3 = current_w3.get()
assert chain.chain_id == await w3.eth.chain_id chain = current_chain.get()
current_clock.set(BlockClock()) assert chain.chain_id == await w3.eth.chain_id
prev_head = None current_clock.set(BlockClock())
while self.running: prev_head = None
try: while self.running:
async with asyncio.timeout(1): # check running flag every second
head = await self.queue.get()
except TimeoutError:
log.debug('timeout in runner')
# 1 second has passed without a new head. Run the postprocess callbacks to check for activated time-based triggers
if prev_head is not None:
await self.handle_time_tick(head)
else:
try: try:
log.debug('handle head...') async with asyncio.timeout(1): # check running flag every second
await self.handle_head(chain, head, w3) head = await self.queue.get()
log.debug('handled') except TimeoutError:
prev_head = head log.debug('timeout in runner')
except Exception as x: # 1 second has passed without a new head. Run the postprocess callbacks to check for activated time-based triggers
log.exception(x) if prev_head is not None:
log.debug('runner worker exiting') await self.handle_time_tick(head)
else:
try:
log.debug('handle head...')
await self.handle_head(chain, head, w3)
log.debug('handled')
prev_head = head
except Exception as x:
log.exception(x)
except:
log.exception('exception in runner worker')
raise
finally:
log.debug('runner worker exiting')
async def handle_head(self, chain, blockhash, w3): async def handle_head(self, chain, blockhash, w3):