Przeglądaj źródła

Chain.link_error should not overwrite individual errbacks. Closes #2547

Ask Solem 9 lat temu
rodzic
commit
a0269898e5
1 zmienionych plików z 1 dodań i 1 usunięć
  1. 1 1
      celery/canvas.py

+ 1 - 1
celery/canvas.py

@@ -527,7 +527,7 @@ class chain(Signature):
                 task.set_parent_id(parent_id)
 
             if link_error:
-                task.set(link_error=link_error)
+                task.link_error(link_error)
 
             tasks.append(task)
             results.append(res)