我更改了我的celery任务所在目录的名称(从下面的错误判断)导致我未来的计划任务出现问题。
KeyError: 'utils.tasks.foo'
[2019-02-21 06:25:09,103: ERROR/MainProcess] Received unregistered task of type 'utils.tasks.foo'.
The message has been ignored and discarded.
此任务现在在services.tasks.foo
下注册。我知道我有更多的任务安排,可以查看我的Redis代理中的任务ID,但是当我使用app.control.inspect().scheduled()
查看计划任务时,只返回自我将目录更改为services.tasks.foo
后已安排的任务。
鉴于Celery没有识别我的旧任务,我如何更新任务名称以匹配我的任务现在注册的路径?
这就是为什么明确地命名任务(参见docs)是一个好主意,因为有时候你想要重新组织你的代码。同时,如已经建议的那样重新创建旧任务可能是个好主意。