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

log when runner is behind

Browse Source
This commit is contained in:
tim
2024-10-22 23:58:34 -04:00
parent 070913b848
commit f9f13daea7
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/dexorder/runner.py
View File

@@ -213,6 +213,7 @@ class BlockStateRunner(BlockProgressor):
async def worker(self): async def worker(self):
was_behind = False
try: try:
log.info(f'Runner started') log.info(f'Runner started')
w3 = current_w3.get() w3 = current_w3.get()
@@ -263,6 +264,14 @@ class BlockStateRunner(BlockProgressor):
else: else:
log.info(f'Reverting {fork.branch} due to {e}') # runtime exception like SystemExit log.info(f'Reverting {fork.branch} due to {e}') # runtime exception like SystemExit
self.state.remove_branch(fork.branch) self.state.remove_branch(fork.branch)
processed_block = await get_block(fork.head)
behind = timestamp() - processed_block.timestamp
if behind > 2:
# todo pagerduty alerts if too far behind
log.info(f'Runner is {timedelta(seconds=behind)} behind')
was_behind = True
elif was_behind:
log.info('Runner has caught up')
except Exception as e: except Exception as e:
fatal('Unhandled exception in runner worker', exception=e) fatal('Unhandled exception in runner worker', exception=e)
finally: finally: