PersonalPublic/mosgortrans
1
0
Fork 0
mirror of https://github.com/Balshgit/mosgortrans.git synced 2025-09-11 13:00:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

add async queue

Browse Source
This commit is contained in:
Dmitry Afanasyev 2022-08-20 02:45:23 +03:00
parent fec8923eed
commit 5e3676cd5e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
app/main.py
View File

@ -86,8 +86,9 @@ async def webhook(request: web.Request) -> web.Response:
""" """
data = await request.json() data = await request.json()
tg_update = Update(**data) tg_update = Update(**data)
queue.put_nowait(tg_update)
logger.info(tg_update) logger.info(tg_update)
queue.put_nowait(tg_update)
logger.info('Put in queue')
return web.Response(status=HTTPStatus.ACCEPTED) return web.Response(status=HTTPStatus.ACCEPTED)