Consecutive groups in chain fails #4848
Description
Checklist
- I have included the output of
celery -A proj reportin the issue.
(if you are not able to do this, then at least specify the Celery
version affected).
CELERY 4.2.0 - I have verified that the issue exists against the
masterbranch of Celery.
Steps to reproduce
chain(
group(task1.s(), task2().s()),
group(task3.s(), task4().s()),
task5.s(),
)
Expected behavior
It works when I put task5.s() task between two groups but when I add consecutive groups in the chain, it fails with "AttributeError: 'GroupResult' object has no attribute 'task_id'" error.
Actual behavior
No messages purged from 1 queue
Traceback (most recent call last):
File "///home/cyildiz/projects/infrastructures/run-scripts/../src//start.py", line 139, in <module>
start(validate_args)
File "///home/cyildiz/projects/infrastructures/run-scripts/../src//start.py", line 85, in start
wf.delay()
File "/home/cyildiz/Projects/env/infra/local/lib/python2.7/site-packages/celery/canvas.py", line 179, in delay
return self.apply_async(partial_args, partial_kwargs)
File "/home/cyildiz/Projects/env/infra/local/lib/python2.7/site-packages/celery/canvas.py", line 557, in apply_async
dict(self.options, **options) if options else self.options))
File "/home/cyildiz/Projects/env/infra/local/lib/python2.7/site-packages/celery/canvas.py", line 573, in run
task_id, group_id, chord,
File "/home/cyildiz/Projects/env/infra/local/lib/python2.7/site-packages/celery/canvas.py", line 655, in prepare_steps
task_id=prev_res.task_id, root_id=root_id, app=app,
AttributeError: 'GroupResult' object has no attribute 'task_id'