瀏覽代碼

Added failing test cases for #3885

Contributed by @robpogorzelski
Omer Katz 8 年之前
父節點
當前提交
8deca44c1e
共有 1 個文件被更改,包括 17 次插入0 次删除
  1. 17 0
      t/unit/tasks/test_canvas.py

+ 17 - 0
t/unit/tasks/test_canvas.py

@@ -647,6 +647,23 @@ class test_chord(CanvasCase):
         x.freeze()
         x.tasks = [self.add.s(2, 2)]
         x.freeze()
+        
+    def test_apply_async_task_in_chained_chords(self):
+        x = chain(
+            chord([self.add.si(1, 2)], body=self.mul.s(4), app=self.app),
+            chord([self.add.si(3, 4)], body=self.mul.s(4), app=self.app)
+        )
+        x.apply_async()
+
+    def test_apply_async_task_in_nested_chords(self):
+        x = chord(
+            [
+                chord([self.add.si(5, 6)], body=self.mul.s(4), app=self.app),
+            ],
+            body=self.mul.s(4),
+            app=self.app
+        )
+        x.apply_async()
 
 
 class test_maybe_signature(CanvasCase):