@@ -85,14 +85,17 @@ def build_registered_span(self, span):
8585 baggage = span .context .baggage ,
8686 custom = sd .CustomData (tags = span .tags ,
8787 logs = self .collect_logs (span )))
88+ entityFrom = { 'e' : self .sensor .agent .from_ .pid ,
89+ 'h' : self .sensor .agent .from_ .agentUuid }
90+
8891 return sd .InstanaSpan (
8992 n = span .operation_name ,
9093 t = span .context .trace_id ,
9194 p = span .parent_id ,
9295 s = span .context .span_id ,
9396 ts = int (round (span .start_time * 1000 )),
9497 d = int (round (span .duration * 1000 )),
95- f = self . sensor . agent . from_ ,
98+ f = entityFrom ,
9699 ec = self .get_tag (span , "ec" ),
97100 error = self .get_tag (span , "error" ),
98101 data = data )
@@ -111,6 +114,8 @@ def build_sdk_span(self, span):
111114
112115 sdk_data .Type = self .get_span_kind (span )
113116 data = sd .Data (service = self .get_service_name (span ), sdk = sdk_data )
117+ entityFrom = { 'e' : self .sensor .agent .from_ .pid ,
118+ 'h' : self .sensor .agent .from_ .agentUuid }
114119
115120 return sd .InstanaSpan (
116121 t = span .context .trace_id ,
@@ -119,7 +124,7 @@ def build_sdk_span(self, span):
119124 ts = int (round (span .start_time * 1000 )),
120125 d = int (round (span .duration * 1000 )),
121126 n = "sdk" ,
122- f = self . sensor . agent . from_ ,
127+ f = entityFrom ,
123128 data = data )
124129
125130 def get_tag (self , span , tag ):
0 commit comments