diff --git a/src/dexorder/runner.py b/src/dexorder/runner.py
index cfa2e20..fb4d34c 100644
--- a/src/dexorder/runner.py
+++ b/src/dexorder/runner.py
@@ -402,11 +402,12 @@ class BlockStateRunner:
                 self.state.delete_block(block.hash)
             if config.parallel_logevent_queries:
                 for get_logs, *_ in batches:
-                    # noinspection PyBroadException
-                    try:
-                        await get_logs
-                    except Exception:
-                        log.exception('exception while querying logs')
+                    if get_logs is not None:
+                        # noinspection PyBroadException
+                        try:
+                            await get_logs
+                        except Exception:
+                            log.exception('exception while querying logs')
             raise
         else:
             if session is not None: