feat: fix

2025-04-09 15:52:41 +03:00
parent 2730ced37e
commit 978a684278
1 changed files with 2 additions and 2 deletions
--- a/main.py
+++ b/main.py
@@ -29,7 +29,7 @@ async def lifespan(app: FastAPI):
    consumer_task = asyncio.create_task(consume_messages())

    yield
-
+    if producer:
        await producer.stop()
    consumer_task.cancel()