Всем привет Не завалялся случаем у кого примерчик на селери хороший? Весь

как я понял, через сигналы @app.task(bind=True, name='test_handler_name', max_retries=2, default_retry_delay=1) def test_handler(self: Task, service: str, kind, *args, **kwargs): print(service) @task_prerun.connect(sender=test_handler) def test_task_prerun(task_id: int, task: Task, *args, **kwargs): kwargs['kwargs'].update(dict(service='any service')) что-то типа такого

0

13.09.2021

Tishka17

Zack!?
как я понял, через сигналы @app.task(bind=True, n...

хм, а интересно

0

13.09.2021

Tishka17

Zack!?
как я понял, через сигналы @app.task(bind=True, n...

@worker_process_init.connect() def worker_init_config(**kwargs): if hasattr(current_app, "Session"): logger.info("App already has Session, skipping creation") return # workaround for threaded workers sharing single app current_app.Session = get_session_factory() current_app.s3config = get_s3_config() current_app.s3 = get_s3(current_app.s3config) я вот так делал, а дальше типа внутри таски уже всю логику

0

13.09.2021

Zack!? Автор вопроса

Tishka17
@worker_process_init.connect() def worker_init_con...

о, можно просто в аппку класть оказывается так вот и получается, что-то глобальное можно открывать в worker_process_init и закрывать в worker_process_shutdown (например коннект к БД) а какие-то сервисы собирать уже в task_prerun используя объекты из апки и сервисы прокидывать в таску

0

13.09.2021

Alex · Accepted Answer

Alex

У селери хорошая дока так-то.

0

13.09.2021

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

Всем привет Не завалялся случаем у кого примерчик на селери хороший? Весь

8 ответов

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