From 978a684278a8e23c6d4331ca37619ff88541e830 Mon Sep 17 00:00:00 2001 From: admin Date: Wed, 9 Apr 2025 15:52:41 +0300 Subject: [PATCH] feat: fix --- main.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main.py b/main.py index e038f6b..60f7b13 100644 --- a/main.py +++ b/main.py @@ -29,8 +29,8 @@ async def lifespan(app: FastAPI): consumer_task = asyncio.create_task(consume_messages()) yield - - await producer.stop() + if producer: + await producer.stop() consumer_task.cancel()