|
11 | 11 | from agentex.types.span import Span |
12 | 12 | from agentex.lib.utils.logging import make_logger |
13 | 13 | from agentex.lib.utils.model_utils import recursive_model_dump |
14 | | -from agentex.lib.core.tracing.obs_ids import obs_correlation |
15 | 14 | from agentex.lib.core.tracing.span_error import set_span_error |
16 | 15 | from agentex.lib.core.tracing.span_queue import ( |
17 | 16 | SpanEventType, |
@@ -80,12 +79,6 @@ def start_span( |
80 | 79 |
|
81 | 80 | serialized_input = recursive_model_dump(input) if input else None |
82 | 81 | serialized_data = recursive_model_dump(data) if data else None |
83 | | - # Tag the business span with the active observability trace_id/span_id |
84 | | - # (OTel/ddtrace) so it can be correlated to the per-turn obs trace. The |
85 | | - # business trace_id stays the run-level task id -- see obs_ids.py. |
86 | | - obs = obs_correlation() |
87 | | - if obs: |
88 | | - serialized_data = {**(serialized_data or {}), **obs} |
89 | 82 | id = str(uuid.uuid4()) |
90 | 83 |
|
91 | 84 | span = Span( |
@@ -236,12 +229,6 @@ async def start_span( |
236 | 229 |
|
237 | 230 | serialized_input = recursive_model_dump(input) if input else None |
238 | 231 | serialized_data = recursive_model_dump(data) if data else None |
239 | | - # Tag the business span with the active observability trace_id/span_id |
240 | | - # (OTel/ddtrace) so it can be correlated to the per-turn obs trace. The |
241 | | - # business trace_id stays the run-level task id -- see obs_ids.py. |
242 | | - obs = obs_correlation() |
243 | | - if obs: |
244 | | - serialized_data = {**(serialized_data or {}), **obs} |
245 | 232 | id = str(uuid.uuid4()) |
246 | 233 |
|
247 | 234 | span = Span( |
|
0 commit comments