소스 검색

Fix the taskset set.

Ask Solem 16 년 전
부모
커밋
0f33f97dee
1개의 변경된 파일3개의 추가작업 그리고 1개의 파일을 삭제
  1. 3 1
      celery/tests/test_task.py

+ 3 - 1
celery/tests/test_task.py

@@ -121,7 +121,9 @@ class TestTaskSet(unittest.TestCase):
         self.assertEquals(ts.task_name, IncrementCounterTask.name)
         self.assertEquals(ts.total, 9)
 
-        taskset_id, subtask_ids = ts.run()
+        taskset_res = ts.run()
+        subtask_ids = taskset_res.subtask_ids
+        taskset_id = taskset_res.taskset_id
 
         consumer = IncrementCounterTask().get_consumer()
         for subtask_id in subtask_ids: