bug fix

Bot-detector · Aug 5, 2024 · 714fff2 · 714fff2
1 parent 3adaafd
commit 714fff2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main.py b/src/main.py
@@ -194,7 +194,9 @@ async def main():
             batch_size=BATCH_SIZE, batch_queue=batch_queue, report_queue=report_queue
         )
     )
-    asyncio.create_task(insert_batch(batch_queue=batch_queue))
+    asyncio.create_task(
+        insert_batch(batch_queue=batch_queue, error_queue=producer.send_queue)
+    )
 
     while True:
         await asyncio.sleep(60)