bug fix

Bot-detector · Aug 5, 2024 · 03fb7ab · 03fb7ab
1 parent f1e5525
commit 03fb7ab
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/src/main.py b/src/main.py
@@ -75,14 +75,20 @@ async def insert_batch(batch_queue: Queue, error_queue: Queue):
         except OperationalError as e:
             logger.error({"error": e})
             await asyncio.gather(
-                *[error_queue.put(convert_stg_to_kafka_report(m)) for m in batch]
+                *[
+                    error_queue.put(convert_stg_to_kafka_report(m).model_dump())
+                    for m in batch
+                ]
             )
             await asyncio.sleep(5)
         except Exception as e:
             logger.error({"error": e})
             logger.debug(f"Traceback: \n{traceback.format_exc()}")
             await asyncio.gather(
-                *[error_queue.put(convert_stg_to_kafka_report(m)) for m in batch]
+                *[
+                    error_queue.put(convert_stg_to_kafka_report(m).model_dump())
+                    for m in batch
+                ]
             )
             await asyncio.sleep(5)