Celery:查询待处理任务的标准方法？

Question

是否存在基于某些字段查询待处理任务的标准/后端无关方法？

例如,我有一个任务需要在"最后一次用户交互"之后运行一次,我想实现它类似于:

def user_changed_content():
    task = find_task(name="handle_content_change")
    if task is None:
        task = queue_task("handle_content_change")
    task.set_eta(datetime.now() + timedelta(minutes=5))
    task.save()

或者直接挂接到存储后端更简单？

Answer 1

不,这是不可能的.

即使某些传输可能支持无序访问"队列"(例如Redis),也不是一个好主意.

该任务可能不再在队列中,而是由工作人员保留.

请参阅文档中的此部分:http://docs.celeryproject.org/en/latest/userguide/tasks.html#state

鉴于此,一个更好的方法是检查它是否应该在启动时重新安排自己的任务:

@task
def reschedules():
    new_eta = redis.get(".".join([reschedules.request.task_id, "new_eta"])
    if new_eta:
         return reschedules.retry(eta=new_eta)