send_message

Bot-detector · May 21, 2024 · 5247b2b · 5247b2b
1 parent 96ad9e7
commit 5247b2b
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/src/core/server.py b/src/core/server.py
@@ -42,6 +42,14 @@ async def lifespan(app: FastAPI):
     logger.info("startup initiated")
     config.producer = await _kafka.kafka_producer()
     config.send_queue = asyncio.Queue(maxsize=500)
+    asyncio.create_task(
+        _kafka.send_messages(
+            topic="report",
+            producer=config.producer,
+            send_queue=config.send_queue,
+            shutdown_event=config.sd_event,
+        )
+    )
     yield
     config.sd_event.set()
     await config.producer.stop()