@@ -56,12 +56,13 @@ def task_prerun_callback(task=None, **kwargs):
5656 if parent_task_id :
5757 tracked_request .tag ("parent_task_id" , parent_task_id )
5858
59- delivery_info = task .request .delivery_info
60- tracked_request .tag ("is_eager" , delivery_info .get ("is_eager" , False ))
61- tracked_request .tag ("exchange" , delivery_info .get ("exchange" , "unknown" ))
62- tracked_request .tag ("priority" , delivery_info .get ("priority" , "unknown" ))
63- tracked_request .tag ("routing_key" , delivery_info .get ("routing_key" , "unknown" ))
64- tracked_request .tag ("queue" , delivery_info .get ("queue" , "unknown" ))
59+ delivery_info = getattr (task .request , "delivery_info" , None )
60+ if delivery_info :
61+ tracked_request .tag ("is_eager" , delivery_info .get ("is_eager" , False ))
62+ tracked_request .tag ("exchange" , delivery_info .get ("exchange" , "unknown" ))
63+ tracked_request .tag ("priority" , delivery_info .get ("priority" , "unknown" ))
64+ tracked_request .tag ("routing_key" , delivery_info .get ("routing_key" , "unknown" ))
65+ tracked_request .tag ("queue" , delivery_info .get ("queue" , "unknown" ))
6566
6667 tracked_request .start_span (operation = ("Job/" + task .name ))
6768
0 commit comments