【发布时间】:2013-07-02 08:36:21
【问题描述】:
我有这个我的项目文件夹结构
api
-- __init__.py
--jobs/
-- __init__.py
-- celery.py
-- celeyconfig.py
-- tasks.py
--api_helpers/
--views/
tasks 有一个名为ExamineColumns的任务
我使用celery worker -A api.jobs --loglevel=Info启动worker
它工作正常,我可以运行任务。
这是 celery 检查命令的输入
$ celery inspect registered
-> ranjith-ThinkPad-T420: OK
* ExamineColumns
* celery.backend_cleanup
* celery.chain
* celery.chord
* celery.chord_unlock
* celery.chunks
* celery.group
* celery.map
* celery.starmap
但是当我尝试多模式时,它根本不起作用。我正在尝试通过运行来运行
celery multi start w1 -c3 -A api.jobs --loglevel=Info
但它根本没有开始。
$ celery inspect registered
Error: No nodes replied within time constraint.
我不知道为什么它不起作用
【问题讨论】:
标签: celery celery-task celeryd