fix: surface errors in persistence when saving results

ApeWorX · Nov 24, 2023 · 29fa6ce · 29fa6ce
1 parent e96e4f2
commit 29fa6ce
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/silverback/runner.py b/silverback/runner.py
@@ -54,7 +54,10 @@ async def _handle_result(
                 self.ident, handler_id, block_number, log_index, result
             )
 
-            await self.persistence.add_result(handler_result)
+            try:
+                await self.persistence.add_result(handler_result)
+            except Exception as err:
+                logger.error(f"Error storing result: {err}")
 
     async def _checkpoint(
         self, last_block_seen: int = 0, last_block_processed: int = 0
@@ -74,9 +77,12 @@ async def _checkpoint(
             self.last_block_processed = max(last_block_processed, self.last_block_processed)
 
             if self.persistence:
-                await self.persistence.set_instance_state(
-                    self.ident, self.last_block_seen, self.last_block_processed
-                )
+                try:
+                    await self.persistence.set_instance_state(
+                        self.ident, self.last_block_seen, self.last_block_processed
+                    )
+                except Exception as err:
+                    logger.error(f"Error settings state: {err}")
 
         return self.last_block_seen, self.last_block_processed