9

我正在使用 Celery 3.1.16 代理（运行 RabbitMQ）和多个 Celery 工作人员，其中 celeryd 通过主管进行了守护。问题在于任务更新。当我更新我的 tasks.py 文件时，celery worker 运行旧代码。

芹菜启动命令：

/home/my_project/bin/celery -B --autoreload --app=my_app.celery:app worker --loglevel=INFO

我在 django settings.py 中包含任务文件：

CELERY_IMPORTS = [
    'my_app.tasks'
]

pyinotify已安装并且可以工作（我猜是这样），它是 celery 日志的一部分：

[2014-12-16 20:56:00,016: INFO/MainProcess] Task my_app.tasks.periodic_update_task_statistic[175c2557-7c07-43c3-ac70-f4e115344134] succeeded in 0.00816309102811s: 'ok!'
[2014-12-16 20:56:11,157: INFO/MainProcess] Detected modified modules: ['my_app.tasks']
[2014-12-16 20:57:00,001: INFO/Beat] Scheduler: Sending due task my_app.tasks.periodic_update_task_statistic (my_app.tasks.periodic_update_task_statistic)
[2014-12-16 20:57:00,007: INFO/MainProcess] Received task: my_app.tasks.periodic_update_task_statistic[f22998a9-dcb4-4c29-8086-86dd6e57eae1]

所以，我的问题是：如果它们被修改，如何获取 celery 更新和应用新任务代码？

4

3 回答 3

2

芹菜对此问题有未解决的问题 https://github.com/celery/celery/issues/1025

于 2016-03-30T12:36:43.150 回答
1

我有着同样的问题。虽然我不喜欢它，但我执行以下操作，首先删除并编译当前目录下任何位置的 .pyc 文件，然后重新启动所有工作人员。 标志什么都不做 find . -name "*.pyc" -exec rm {} \; supervisorctl restart all 似乎很奇怪，但在我的情况下却没有。--autoreload

于 2015-02-02T20:55:08.410 回答
1

Celery 只会自动重新加载它直接加载的那些模块，它不会关注由直接模块加载的其他模块。

于 2016-01-05T00:47:19.990 回答