From 3685930d554309d57039de3060de3fb3a119ecc8 Mon Sep 17 00:00:00 2001 From: Tim Date: Wed, 3 Apr 2024 14:55:17 -0400 Subject: [PATCH] comment --- src/dexorder/runner.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/dexorder/runner.py b/src/dexorder/runner.py index a9ea51b..82927cc 100644 --- a/src/dexorder/runner.py +++ b/src/dexorder/runner.py @@ -230,7 +230,7 @@ class BlockStateRunner(BlockProgressor): if isinstance(e, Exception): log.exception(f'Reverting {fork.branch} due to exception') else: - log.info(f'Reverting {fork.branch} due to {e}') + log.info(f'Reverting {fork.branch} due to {e}') # runtime exception like SystemExit self.state.remove_branch(fork.branch) except Exception: log.exception('Unhandled exception in runner worker') @@ -240,7 +240,6 @@ class BlockStateRunner(BlockProgressor): async def process(self, fork: Fork): - log.debug(f'processing {fork}') chain = current_chain.get() w3 = current_w3.get() current_blockstate.set(self.state) @@ -285,7 +284,7 @@ class BlockStateRunner(BlockProgressor): current_pub.set(lambda room, evnt, *args: pubs.append((room, evnt, args))) # used by handle_vault_created if not self.state_initialized: await self.do_state_init_cbs() - log.debug(f'invoking callbacks with fork {current_fork.get()}') + # log.debug(f'invoking callbacks with fork {current_fork.get()}') await self.invoke_callbacks(batches) # todo @@ -310,7 +309,7 @@ class BlockStateRunner(BlockProgressor): # todo try/except for known retryable errors # noinspection PyCallingNonCallable await maywait(callback(promotion_fork, diff_items)) - except Exception: # legitimately catch EVERYTHING because we re-raise + except Exception: # legitimately catch EVERYTHING because we re-raise. worker() does the catching. log.debug('rolling back session') if session is not None: session.rollback()