Forráskód Böngészése

Chord error handler should account for anon-task (Issue #3461)

Ask Solem 8 éve
szülő
commit
bc3e272f72
1 módosított fájl, 4 hozzáadás és 1 törlés
  1. 4 1
      celery/backends/base.py

+ 4 - 1
celery/backends/base.py

@@ -193,7 +193,10 @@ class Backend(object):
         # need below import for test for some crazy reason
         from celery import group  # pylint: disable
         app = self.app
-        backend = app._tasks[callback.task].backend
+        try:
+            backend = app._tasks[callback.task].backend
+        except KeyError:
+            backend = self
         try:
             group(
                 [app.signature(errback)