1

我正在使用CeleryFlowerRedis的最新版本,但我不明白发生了什么。我得到了所有结果,并且数据正确返回,但是当我使用 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中显示,所以我认为任务必须仍然存在(占用内存)。

这是真的?有没有想过让他们消失?

谢谢!

4

0 回答 0