revert backgroundtasks in bot update handler
This commit is contained in:
@@ -32,21 +32,13 @@ async def telegram_webhook(
|
|||||||
except Exception:
|
except Exception:
|
||||||
logger.error("Invalid request", exc_info=True)
|
logger.error("Invalid request", exc_info=True)
|
||||||
return Response(status_code=400)
|
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(
|
background_tasks.add_task(
|
||||||
# feed_bot_update,
|
feed_bot_update,
|
||||||
# app=app,
|
app=app,
|
||||||
# update=update,
|
update=update,
|
||||||
# app_state=request.state,
|
app_state=request.state,
|
||||||
# )
|
)
|
||||||
return Response(status_code=200)
|
return Response(status_code=200)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -78,7 +78,7 @@ class DbStorage(BaseStorage):
|
|||||||
db_data = (
|
db_data = (
|
||||||
await session.exec(select(FSMStorage).where(FSMStorage.key == db_key))
|
await session.exec(select(FSMStorage).where(FSMStorage.key == db_key))
|
||||||
).first()
|
).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):
|
async def close(self):
|
||||||
return await super().close()
|
return await super().close()
|
||||||
|
|||||||
Reference in New Issue
Block a user