Regen working on Python 2.5

celery/app/builtins.py

@@ -219,6 +219,8 @@ def add_chord_task(app):
                 opts["chord"] = body
                 opts["taskset_id"] = setid
                 r.append(app.AsyncResult(tid))
+            if eager:
+                return header.apply(task_id=setid)
             app.backend.on_chord_apply(setid, body,
                                        interval=interval,
                                        max_retries=max_retries,
@@ -238,9 +240,11 @@ def add_chord_task(app):
             body_result.parent = parent
             return body_result
 
-        def apply(self, args=(), kwargs={}, **options):
+        def apply(self, args=(), kwargs={}, propagate=True, **options):
             body = kwargs["body"]
-            res = super(Chord, self).apply(args, kwargs, **options)
-            return maybe_subtask(body).apply(args=(res.get().join(), ))
+            res = super(Chord, self).apply(args, dict(kwargs, eager=True),
+                                           **options)
+            return maybe_subtask(body).apply(
+                        args=(res.get(propagate=propagate).get().join(), ))
 
     return Chord

celery/canvas.py

@@ -333,7 +333,7 @@ class chord(Signature):
         _chord = self.Chord
         self.kwargs["body"] = body or self.kwargs["body"]
         if _chord.app.conf.CELERY_ALWAYS_EAGER:
-            return _chord.apply((), self.kwargs)
+            return self.apply((), {}, **options)
         callback_id = body.options.setdefault("task_id", uuid())
         _chord(**self.kwargs)
         return _chord.AsyncResult(callback_id)

celery/utils/functional.py

@@ -256,6 +256,9 @@ class _regen(UserList, list):
     def data(self):
         return list(self.__it)
 
+    def __iter__(self):  # needed for Python 2.5
+        return iter(self.data)
+
 
 def regen(it):
     if isinstance(it, (list, tuple)):