浏览代码

map() must now use ts.run().join() now that TaskSet.join() is gone

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

+ 1 - 1
celery/task/base.py

@@ -525,7 +525,7 @@ class TaskSet(object):
     def map(cls, func, args, timeout=None):
         """Distribute processing of the arguments and collect the results."""
         remote_task = cls.remote_execute(func, args)
-        return remote_task.join(timeout=timeout)
+        return remote_task.run().join(timeout=timeout)
 
     @classmethod
     def map_async(cls, func, args, timeout=None):