chore: debug instrumentation

ApeWorX · Dec 4, 2023 · 55c7f78 · 55c7f78
1 parent 4426342
commit 55c7f78
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/silverback/runner.py b/silverback/runner.py
@@ -157,8 +157,13 @@ async def _block_task(self, block_handler: AsyncTaskiqDecoratedTask):
         logger.debug(f"Handling blocks via {sub_id}")
 
         async for raw_block in self.subscriptions.get_subscription_data(sub_id):
+            logger.debug("Processing raw block:")
+            print(raw_block)
+
             block = self.provider.network.ecosystem.decode_block(hexbytes_dict(raw_block))
 
+            logger.debug(f"Received block: {block.number or 'pending'}")
+
             if block.number is not None:
                 await self._checkpoint(last_block_seen=block.number)