Skip to content

feat: Adding Agent info to SGP tracing metadata #85

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 13 commits into from
Oct 2, 2025
Merged

feat: Adding Agent info to SGP tracing metadata #85

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
7114e5b
Update sgp_tracing_processor.py
smoreinis Aug 18, 2025
48b9d50
Merge branch 'main' into stas/trace-agentex-source
smoreinis Aug 19, 2025
ce3f992
Merge branch 'main' into stas/trace-agentex-source
smoreinis Sep 8, 2025
17257bb
Update sgp_tracing_processor.py
smoreinis Sep 8, 2025
83b158b
Merge branch 'main' into stas/trace-agentex-source
smoreinis Sep 8, 2025
5ce6393
Update sgp_tracing_processor.py
smoreinis Sep 8, 2025
bd550e0
Merge branch 'main' into stas/trace-agentex-source
smoreinis Sep 30, 2025
db16b17
Update sgp_tracing_processor.py
smoreinis Oct 1, 2025
85268d6
Merge branch 'main' into stas/trace-agentex-source
smoreinis Oct 1, 2025
06a3db0
Update sgp_tracing_processor.py
smoreinis Oct 1, 2025
bb30569
Update sgp_tracing_processor.py
smoreinis Oct 1, 2025
f059431
Merge branch 'main' into stas/trace-agentex-source
smoreinis Oct 2, 2025
7ffc109
Merge branch 'main' into stas/trace-agentex-source
smoreinis Oct 2, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 15 additions & 0 deletions src/agentex/lib/core/tracing/processors/sgp_tracing_processor.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,8 +25,15 @@ def __init__(self, config: SGPTracingProcessorConfig):
)
self._spans: dict[str, SGPSpan] = {}

def _add_source_to_span(self, span: Span) -> None:
if span.data is None:
span.data = {}
span.data["source"] = "agentex"

@override
def on_span_start(self, span: Span) -> None:
self._add_source_to_span(span)

sgp_span = create_span(
name=span.name,
span_id=span.id,
Expand All @@ -50,6 +57,7 @@ def on_span_end(self, span: Span) -> None:
)
return

self._add_source_to_span(span)
sgp_span.output = span.output
sgp_span.metadata = span.data
sgp_span.end_time = span.end_time.isoformat()
Expand All @@ -71,8 +79,14 @@ def __init__(self, config: SGPTracingProcessorConfig):
else None
)

def _add_source_to_span(self, span: Span) -> None:
if span.data is None:
span.data = {}
span.data["source"] = "agentex"

@override
async def on_span_start(self, span: Span) -> None:
self._add_source_to_span(span)
sgp_span = create_span(
name=span.name,
span_id=span.id,
Expand Down Expand Up @@ -101,6 +115,7 @@ async def on_span_end(self, span: Span) -> None:
)
return

self._add_source_to_span(span)
sgp_span.output = span.output
sgp_span.metadata = span.data
sgp_span.end_time = span.end_time.isoformat()
Expand Down
Loading