Я использую последние версии Сельдерей и Цветок и Redis , но я не могу понять, что происходит. Я получаю все результаты для работы, и данные возвращаются правильно, но когда я просматриваю Задачи Сельдерея с Цветком, я вижу все задачи и результаты.
В моей задаче есть следующий декоратор:
@celery.task(ignore_result=True, bind=True)
def perform_long_task(self, urls):
Я пытался позвонить get()
, forget()
и т. Д., Но когда я смотрю на Флауэр, результаты всегда есть.
Я также пробовал:
CELERY_TASK_RESULT_EXPIRES=10
Я запускаю задачу с:
celery worker -l info -B -A test.api.tasks
Я пробовал:
class CeleryConfig:
CELERYBEAT_SCHEDULE = {
'check-every-minute': {
'task': 'celery.backend_cleanup',
'schedule': crontab(hour="*/1"),
}
}
Я не могу заставить таксы не показываться в Flower, поэтому я думаю, что задачи все еще должны быть там (занимая память).
Это правда? Есть мысли заставить их исчезнуть?
Спасибо!