Failed task in a group nested in a group can result in a timeout #10002
Unanswered
Pierre-Morin
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
Hi, I'm testing Celery's error handling on 5.6.0rc1 for our project and I ran into what seems to be a bug. I created the test below to reproduce the issue with a simple code (it can be appended to test_chord class from t/integration/test_canvas.py). This chain results in a timeout instead of raising an expected exception. I added some printing to check the tasks status and we can see the FAILURE state is not propagated to all tasks. However, I'm not familiar enough with Celery to say if this propagation is expected or not. What makes me think it has to do with state propagation is that when I remove the
mul.s(11)line, I no longer get a timeout but a ChordError.Print output:
If you need any additional informations, please tell me.
Beta Was this translation helpful? Give feedback.
All reactions