feat: raise exception

Airstack-xyz · May 14, 2024 · ce4812a · ce4812a
1 parent 68fb8a3
commit ce4812a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/blockchainetl/jobs/exporters/kafka_exporter.py b/blockchainetl/jobs/exporters/kafka_exporter.py
@@ -58,6 +58,7 @@ def export_items(self, items):
                 future.get(timeout=10)
             except Exception as e:
                 logging.error(f'Failed to send message: {e}')
+                raise e
 
     def export_item(self, item):
         item_type = item.get('type')