@@ -30,13 +30,14 @@ def __init__(self, config: SGPTracingProcessorConfig):
3030 def _add_source_to_span (self , span : Span ) -> None :
3131 if span .data is None :
3232 span .data = {}
33- span .data ["__source__" ] = "agentex"
34- if self .env_vars .ACP_TYPE is not None :
35- span .data ["__acp_type__" ] = self .env_vars .ACP_TYPE
36- if self .env_vars .AGENT_NAME is not None :
37- span .data ["__agent_name__" ] = self .env_vars .AGENT_NAME
38- if self .env_vars .AGENT_ID is not None :
39- span .data ["__agent_id__" ] = self .env_vars .AGENT_ID
33+ if isinstance (span .data , dict ):
34+ span .data ["__source__" ] = "agentex"
35+ if self .env_vars .ACP_TYPE is not None :
36+ span .data ["__acp_type__" ] = self .env_vars .ACP_TYPE
37+ if self .env_vars .AGENT_NAME is not None :
38+ span .data ["__agent_name__" ] = self .env_vars .AGENT_NAME
39+ if self .env_vars .AGENT_ID is not None :
40+ span .data ["__agent_id__" ] = self .env_vars .AGENT_ID
4041
4142 @override
4243 def on_span_start (self , span : Span ) -> None :
@@ -91,13 +92,14 @@ def __init__(self, config: SGPTracingProcessorConfig):
9192 def _add_source_to_span (self , span : Span ) -> None :
9293 if span .data is None :
9394 span .data = {}
94- span .data ["__source__" ] = "agentex"
95- if self .env_vars .ACP_TYPE is not None :
96- span .data ["__acp_type__" ] = self .env_vars .ACP_TYPE
97- if self .env_vars .AGENT_NAME is not None :
98- span .data ["__agent_name__" ] = self .env_vars .AGENT_NAME
99- if self .env_vars .AGENT_ID is not None :
100- span .data ["__agent_id__" ] = self .env_vars .AGENT_ID
95+ if isinstance (span .data , dict ):
96+ span .data ["__source__" ] = "agentex"
97+ if self .env_vars .ACP_TYPE is not None :
98+ span .data ["__acp_type__" ] = self .env_vars .ACP_TYPE
99+ if self .env_vars .AGENT_NAME is not None :
100+ span .data ["__agent_name__" ] = self .env_vars .AGENT_NAME
101+ if self .env_vars .AGENT_ID is not None :
102+ span .data ["__agent_id__" ] = self .env_vars .AGENT_ID
101103
102104 @override
103105 async def on_span_start (self , span : Span ) -> None :
0 commit comments