Просмотр исходного кода

Canvas: group.type should use app of first task. Closes #1516

Ask Solem 11 лет назад
Родитель
Сommit
8649f223a4
1 измененных файлов с 5 добавлено и 0 удалено
  1. 5 0
      celery/canvas.py

+ 5 - 0
celery/canvas.py

@@ -432,6 +432,11 @@ class group(Signature):
 
     def __repr__(self):
         return repr(self.tasks)
+
+    @property
+    def type(self):
+        return self._type or self.tasks[0].type.app.tasks[self['task']]
+
 Signature.register_type(group)