我正在运行的Django +芹菜+ RabbitMQ的。 修改一些任务名称后,我开始变得“未注册的任务” KeyErrors,即使从周期性任务表在Django芹菜此键删除任务,击败并重新启动芹菜工人之后。
事实证明, 芹菜/ RabbitMQ的任务是持久的 。 我最终被解决了问题重新实现遗留任务作为虚拟方法 。
今后,我宁愿不清除队列,重新启动工人或重新实现传统方法。 相反,我想检查队列,并逐个删除任何遗留的任务。 这可能吗? (优选地,在Django管理接口的上下文中)。
我正在运行的Django +芹菜+ RabbitMQ的。 修改一些任务名称后,我开始变得“未注册的任务” KeyErrors,即使从周期性任务表在Django芹菜此键删除任务,击败并重新启动芹菜工人之后。
事实证明, 芹菜/ RabbitMQ的任务是持久的 。 我最终被解决了问题重新实现遗留任务作为虚拟方法 。
今后,我宁愿不清除队列,重新启动工人或重新实现传统方法。 相反,我想检查队列,并逐个删除任何遗留的任务。 这可能吗? (优选地,在Django管理接口的上下文中)。
芹菜inspect
可以帮助
到查看活动队列:
celery -A proj inspect active_queues
要终止一个进程:
celery -A proj control invoke process_id
要查看所有availble的检查选项:
celery inspect --help