chord fails to detect SUCCESSFUL completion of simple tasks
2015-06-19 23:58:05 GMT
I'm wondering if there is something wrong with my configuration, because while there are quite a few posts about problems with chords when the header task(s) fail, there are none that I found that have problems when header tasks succeed!
For me, this is 100% reproducible with a very simple example:
callback = accept_sequence.s()
Called as header.delay(), I can run the header tasks all day long without issue. I get back a group result of [6, 7].
However, if I put it in a chord with a simple callback task, it fails every time. chord_unlock fails the deps ready check and loops forever.
I've tried RabbitMQ, memcached, and redis for my result backend. No difference.
If I remove the chain from header and just run a group of tasks, then chord works fine. A group of chains also works fine. But a chain that feeds a group is broken.
Possibly relevant config items:
CELERY_CHORD_PROPAGATES = True
You received this message because you are subscribed to the Google Groups "celery-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to celery-users+unsubscribe-/JYPxA39Uh5TLH3MbocFFw@public.gmane.org.
To post to this group, send email to celery-users-/JYPxA39Uh5TLH3MbocFFw@public.gmane.org.
Visit this group at http://groups.google.com/group/celery-users.
For more options, visit https://groups.google.com/d/optout.