我正在使用Celery和Flower和Redis的最新版本,但我不明白发生了什么。我得到了所有结果,并且数据正确返回,但是当我使用 Flower 查看 Celery 任务时,我看到了所有任务和结果。
我的任务有以下装饰器:
@celery.task(ignore_result=True, bind=True)
def perform_long_task(self, urls):
我试过调用get()
,forget()
等,但是当我查看 Flower 时,结果总是在那里。
我也试过:
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中显示,所以我认为任务必须仍然存在(占用内存)。
这是真的?有没有想过让他们消失?
谢谢!