diff --git a/tr_sys/tr_ars/api.py b/tr_sys/tr_ars/api.py index f2a2f88d..393164c6 100644 --- a/tr_sys/tr_ars/api.py +++ b/tr_sys/tr_ars/api.py @@ -494,6 +494,7 @@ def message(req, key): #message_to_merge =utils.get_safe(data,"message") message_to_merge = data agent_name = str(mesg.actor.agent.name) + span.set_attribute("agent", agent_name) logger.info("Running pre_merge_process for agent %s with %s" % (agent_name, len(res))) utils.pre_merge_process(message_to_merge,key, agent_name, inforesid) if mesg.data and 'results' in mesg.data and mesg.data['results'] != None and len(mesg.data['results']) > 0: