|
@@ -101,6 +101,7 @@ def default(task, app, consumer,
|
|
|
'task-received',
|
|
|
uuid=req.id, name=req.name,
|
|
|
args=req.argsrepr, kwargs=req.kwargsrepr,
|
|
|
+ root_id=req.root_id, parent_id=req.parent_id,
|
|
|
retries=req.request_dict.get('retries', 0),
|
|
|
eta=req.eta and req.eta.isoformat(),
|
|
|
expires=req.expires and req.expires.isoformat(),
|