chain(
group(task1.s(), task2().s()),
group(task3.s(), task4().s()),
task5.s(),
)
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.
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'
Checklist
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
masterbranch of Celery.Steps to reproduce
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