|
@@ -175,11 +175,11 @@ def add_group_task(app):
|
|
|
if self.request.is_eager or app.conf.CELERY_ALWAYS_EAGER:
|
|
|
return app.GroupResult(
|
|
|
result.id,
|
|
|
- [task.apply(group_id=group_id) for task in taskit],
|
|
|
+ [stask.apply(group_id=group_id) for stask in taskit],
|
|
|
)
|
|
|
with app.producer_or_acquire() as pub:
|
|
|
- [task.apply_async(group_id=group_id, publisher=pub,
|
|
|
- add_to_parent=False) for task in taskit]
|
|
|
+ [stask.apply_async(group_id=group_id, publisher=pub,
|
|
|
+ add_to_parent=False) for stask in taskit]
|
|
|
parent = get_current_worker_task()
|
|
|
if parent:
|
|
|
parent.request.children.append(result)
|