Celery:更新任务名称以匹配已注册的任务

问题描述 投票:0回答:1

我更改了我的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没有识别我的旧任务,我如何更新任务名称以匹配我的任务现在注册的路径?

python django celery
1个回答
1
投票

这就是为什么明确地命名任务(参见docs)是一个好主意,因为有时候你想要重新组织你的代码。同时,如已经建议的那样重新创建旧任务可能是个好主意。

© www.soinside.com 2019 - 2024. All rights reserved.