前几天Celery的机群加了一台机器,
开始没注意,就直接pip install Celery安装了。
发现在新的机器起的job在老的机器无法调用,老的机器发起的job,新的可以跑。
在老机器的日志里有相应的错误信息:
Received and deleted unknown message. Wrong destination?!?
The full contents of the message body was: body:.....
后来还是同事问了一下版本是否一致,才想起来,老的是Celery 3.1.2,新的已经是 4.0.2版本了,差了一个大版本了 。
问题找到了就简单了,卸载,指定版本安装就解决了。