|
@@ -275,7 +275,7 @@ def build_tracer(name, task, loader=None, hostname=None, store_errors=True,
|
|
for group_ in groups:
|
|
for group_ in groups:
|
|
group.apply_async((retval, ))
|
|
group.apply_async((retval, ))
|
|
if sigs:
|
|
if sigs:
|
|
- group(sigs).apply_async(retval, )
|
|
|
|
|
|
+ group(sigs).apply_async((retval, ))
|
|
else:
|
|
else:
|
|
signature(callbacks[0], app=app).delay(retval)
|
|
signature(callbacks[0], app=app).delay(retval)
|
|
if publish_result:
|
|
if publish_result:
|