|
@@ -394,7 +394,9 @@ def build_tracer(name, task, loader=None, hostname=None, store_errors=True,
|
|
|
group(sigs).apply_async((retval,))
|
|
|
else:
|
|
|
signature(callbacks[0], app=app).delay(retval)
|
|
|
- mark_as_done(uuid, retval, task_request, publish_result)
|
|
|
+ mark_as_done(
|
|
|
+ uuid, retval, task_request, publish_result,
|
|
|
+ )
|
|
|
except EncodeError as exc:
|
|
|
I, R, state, retval = on_error(task_request, exc, uuid)
|
|
|
else:
|