Уважаемые, а так вообще можно делать? Подводных камней нет? @shared_task def update_message_status(message_id: str):

Question

Уважаемые, а так вообще можно делать? Подводных камней нет? @shared_task def update_message_status(message_id: str):

loop = asyncio.get_event_loop()
loop.run_until_complete(update_status(message_id))

Кажется не совсем логично в селери прокидывать луп, в нем запускать таску....

#backend #programming #python #russian

0

01.09.2023

7 ответов

18 просмотров

Bulat A. Автор вопроса

Tishka17
а создаешь луп ты где?

Вообще там запускается FastAPI...... и поэтому get_event_loop по ходу..

0

01.09.2023

Tishka17

Bulat A.
Вообще там запускается FastAPI...... и поэтому get...

Зачем запускать фастапи в воркере селери?

0

01.09.2023

Bulat A. Автор вопроса

Tishka17
Зачем запускать фастапи в воркере селери?

наоборот - в коде из FastAPI запускается задача селери через apply_async

0

01.09.2023

Tishka17

Bulat A.
наоборот - в коде из FastAPI запускается задача се...

так ты показал таску. Таска выполяется в воркере

0

01.09.2023

Tishka17

In Python versions 3.10.0–3.10.8 and 3.11.0 this function (and other functions which use it implicitly) emitted a DeprecationWarning if there was no running event loop, even if the current loop was set on the policy. In Python versions 3.10.9, 3.11.1 and 3.12 they emit a DeprecationWarning if there is no running event loop and no current loop is set. In some future Python release this will become an error.

0

01.09.2023

Alex

Bulat A.
наоборот - в коде из FastAPI запускается задача се...

Ну то есть FastAPI к celery не имеет никакого отношения.

0

01.09.2023

Tishka17 · Accepted Answer

Tishka17

а создаешь луп ты где?

0

01.09.2023

170 похожих чатов

Уважаемые, а так вообще можно делать? Подводных камней нет? @shared_task def update_message_status(message_id: str):

7 ответов

Похожие вопросы