From ae036023e5a5ad04f351191fbd3ae84a9ec79ee9 Mon Sep 17 00:00:00 2001 From: Alexander Kalinovsky Date: Sun, 18 May 2025 17:18:58 +0700 Subject: [PATCH] revert backgroundtasks in bot update handler --- src/quickbot/api_route/telegram.py | 20 ++++++-------------- src/quickbot/fsm/db_storage.py | 2 +- 2 files changed, 7 insertions(+), 15 deletions(-) diff --git a/src/quickbot/api_route/telegram.py b/src/quickbot/api_route/telegram.py index 3a0a9f4..172f5e0 100644 --- a/src/quickbot/api_route/telegram.py +++ b/src/quickbot/api_route/telegram.py @@ -32,21 +32,13 @@ async def telegram_webhook( except Exception: logger.error("Invalid request", exc_info=True) return Response(status_code=400) - - await app.dp.feed_webhook_update( - bot=app.bot, - update=update, - db_session=db_session, - app=app, - app_state=request.state, - ) - # background_tasks.add_task( - # feed_bot_update, - # app=app, - # update=update, - # app_state=request.state, - # ) + background_tasks.add_task( + feed_bot_update, + app=app, + update=update, + app_state=request.state, + ) return Response(status_code=200) diff --git a/src/quickbot/fsm/db_storage.py b/src/quickbot/fsm/db_storage.py index 3e90b08..ebc1bd2 100644 --- a/src/quickbot/fsm/db_storage.py +++ b/src/quickbot/fsm/db_storage.py @@ -78,7 +78,7 @@ class DbStorage(BaseStorage): db_data = ( await session.exec(select(FSMStorage).where(FSMStorage.key == db_key)) ).first() - return json.loads(db_data.value) if db_data else {} + return json.loads(db_data.value) if db_data else {} async def close(self): return await super().close()