浏览代码

celery control was not receiving replies

Ask Solem 12 年之前
父节点
当前提交
af459bca55
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      celery/bin/celery.py

+ 1 - 1
celery/bin/celery.py

@@ -614,7 +614,7 @@ class control(_RemoteControl):
     def call(self, method, *args, **options):
     def call(self, method, *args, **options):
         # XXX Python 2.5 doesn't support X(*args, reply=True, **kwargs)
         # XXX Python 2.5 doesn't support X(*args, reply=True, **kwargs)
         return getattr(self.app.control, method)(
         return getattr(self.app.control, method)(
-            *args, **dict(options, retry=True))
+            *args, **dict(options, reply=True))
 
 
     def pool_grow(self, method, n=1, **kwargs):
     def pool_grow(self, method, n=1, **kwargs):
         """[N=1]"""
         """[N=1]"""