Browse Source

Tests passing

Ask Solem 13 years ago
parent
commit
261bd50297
2 changed files with 2 additions and 1 deletions
  1. 1 0
      celery/task/sets.py
  2. 1 1
      celery/tests/test_task/test_chord.py

+ 1 - 0
celery/task/sets.py

@@ -127,6 +127,7 @@ class subtask(AttributeDict):
 
 
 def maybe_subtask(t):
+    print("SUBTASK: %r" % (subtask, ))
     if not isinstance(t, subtask):
         return subtask(t)
     return t

+ 1 - 1
celery/tests/test_task/test_chord.py

@@ -70,7 +70,7 @@ class test_unlock_chord_task(AppCase):
                     unlock("setid", callback,
                            result=map(AsyncResult, [1, 2, 3]))
                 finally:
-                    chords.subtask = subtask
+                    sets.subtask = subtask
                 callback.apply_async.assert_called_with(([2, 4, 8, 6], ), {})
                 # did not retry
                 self.assertFalse(retry.call_count)