Prechádzať zdrojové kódy

Chain did not support anon-subtasks

Ask Solem 12 rokov pred
rodič
commit
7e268d3b24
1 zmenil súbory, kde vykonal 4 pridanie a 1 odobranie
  1. 4 1
      celery/canvas.py

+ 4 - 1
celery/canvas.py

@@ -306,7 +306,10 @@ class chain(Signature):
 
     @property
     def type(self):
-        return self._type or self.tasks[0].type.app.tasks['celery.chain']
+        try:
+            return self._type or self.tasks[0].type.app.tasks['celery.chain']
+        except NotRegistered:
+            return current_app.tasks['celery.chain']
 
     def __repr__(self):
         return ' | '.join(repr(t) for t in self.tasks)