Как остановить выполнение задачи Celery?

Question

[client24]

Есть такая задача
она должна повторятся пока не изменится переменная config.IS_WORK

@app.task(bind=True)
def test(self):
    if config.IS_WORK:
        self.retry(countdown=3)

Переменная изменяется
но задача продолжает выполнятся
celery кэширует задачу?
может есть красивей способ решить мою задачу

Comments

[javedimka]

Как прервать задачу celery?
Как остановить запущенную задачу в celery?

[Сергей Горностаев]

Что меняет переменную IS_WORK?

[client24]

Сергей Горностаев, изменяется во views

[client24]

javedimka, это совсем не то

[Сергей Горностаев]

client24, каждый таск Celery - это отдельный процесс со своими отдельными экземплярами переменных.

[client24]

Сергей Горностаев, уже понял)
но не знаю как сделать правильно
что всё работало
хранить это значения в БД?

[Сергей Горностаев]

client24, чтобы управлять жизненным циклом задач, лучше всего использовать механизмы самого Celery из ссылок в первом комментарии.

[client24]

Сергей Горностаев, Понял
Спсибо!)
Вы мне уже много раз помогли