芹菜取消自己

Question

当我尝试运行一个工人时：

celery -A celery_conf --loglevel=debug worker -Q celery -c 1

好像开始了，但是后来"cancel"s

[2018-08-07 16:25:16,132: INFO/MainProcess] Connected to redis://server:6379/1
[2018-08-07 16:25:23,984: DEBUG/MainProcess] Canceling task consumer...
[2018-08-07 16:25:24,993: DEBUG/MainProcess] Canceling task consumer...
[2018-08-07 16:25:24,993: DEBUG/MainProcess] Closing consumer channel...
[2018-08-07 16:25:24,993: WARNING/MainProcess] Restoring 1 unacknowledged message(s)
[2018-08-07 16:25:24,996: DEBUG/MainProcess] removing tasks from inqueue until task handler finished

知道如何开始调试吗？我已经有了 DEBUG 的日志级别。

Celery 版本：4.2.1（也在 master 上测试过）
Python版本：3.6.6
使用 Redis 代理

Answer 1

将你的 redis-py 降级到 redis>=2.10.0,<3.0.0，或者将你的 celery 版本升级到 4.3.0（我没试过，我失望了）

https://github.com/celery/celery/issues/4495#issuecomment-440438055

芹菜取消自己

Celery cancels itself

python

redis

celery

broker