fix: set MAF framework provider for agent executor spans

Author: sipercai

instrumentation-loongsuite/loongsuite-instrumentation-microsoft-agent-framework/src/opentelemetry/instrumentation/microsoft_agent_framework/span_processor.py

@@ -94,6 +94,7 @@
 _EDGE_GROUP_PROCESS = "edge_group.process"
 _LIVE_SPAN_MAX_AGE_NS = 60 * 1_000_000_000
 _GEN_AI_TOOL_NAME = "gen_ai.tool.name"
+_FRAMEWORK_PROVIDER_NAME = "microsoft.agent_framework"
 
 
 def _attr_value(span: Any, key: str) -> Any:
@@ -876,6 +877,16 @@ def _apply_semantic_attributes(
         normalized = _normalize_provider(provider)
         if normalized is not None and normalized != provider:
             _set_attr(live, GEN_AI_PROVIDER_NAME, normalized)
+        elif (
+            normalized is None
+            and span_kind == GenAISpanKind.AGENT
+            and op_name
+            in {
+                GenAIOperation.CREATE_AGENT,
+                GenAIOperation.INVOKE_AGENT,
+            }
+        ):
+            _set_attr(live, GEN_AI_PROVIDER_NAME, _FRAMEWORK_PROVIDER_NAME)
 
         # 5) Normalize finish reasons written by MAF as a JSON string.
         _normalize_finish_reasons(live, readable)

instrumentation-loongsuite/loongsuite-instrumentation-microsoft-agent-framework/src/opentelemetry/instrumentation/microsoft_agent_framework/util_genai_bridge.py

@@ -76,6 +76,7 @@
     GenAISpanKind,
 )
 from .span_processor import (
+    _FRAMEWORK_PROVIDER_NAME,
     _attr_value,
     _classify_span,
     _is_exception_event,
@@ -598,6 +599,11 @@ def _set_common_live_attributes(
     provider = _normalize_provider(_attr_value(span, GEN_AI_PROVIDER_NAME))
     if provider is not None:
         span.set_attribute(GEN_AI_PROVIDER_NAME, provider)
+    elif span_kind == GenAISpanKind.AGENT and op_name in {
+        GenAIOperation.CREATE_AGENT,
+        GenAIOperation.INVOKE_AGENT,
+    }:
+        span.set_attribute(GEN_AI_PROVIDER_NAME, _FRAMEWORK_PROVIDER_NAME)
     finish_reasons = _finish_reasons(span)
     if finish_reasons:
         span.set_attribute(GEN_AI_RESPONSE_FINISH_REASONS, finish_reasons)

instrumentation-loongsuite/loongsuite-instrumentation-microsoft-agent-framework/tests/test_processor.py

@@ -207,6 +207,9 @@ def test_executor_process_agent_executor_becomes_agent():
     assert (
         s.attributes.get(GEN_AI_OPERATION_NAME) == GenAIOperation.INVOKE_AGENT
     )
+    assert (
+        s.attributes.get(GEN_AI_PROVIDER_NAME) == "microsoft.agent_framework"
+    )
 
 
 def test_executor_process_unknown_executor_stays_workflow_operation():

instrumentation-loongsuite/loongsuite-instrumentation-microsoft-agent-framework/tests/test_util_genai_bridge.py

@@ -303,6 +303,28 @@ def test_agent_span_is_finalized_by_util_genai_before_export(monkeypatch):
     assert span.attributes.get("gen_ai.agent.id") == "agent-1"
 
 
+def test_agent_span_gets_framework_provider_when_missing(monkeypatch):
+    obs_mod, exporter = _install_fake_observability(monkeypatch)
+    util_genai_bridge.apply_util_genai_bridge()
+    try:
+        with obs_mod._get_span(
+            {
+                GEN_AI_OPERATION_NAME: GenAIOperation.INVOKE_AGENT,
+                "gen_ai.agent.name": "planner",
+            },
+            "gen_ai.agent.name",
+        ):
+            pass
+    finally:
+        util_genai_bridge.revert_util_genai_bridge()
+
+    span = exporter.get_finished_spans()[0]
+    assert (
+        span.attributes.get(GEN_AI_PROVIDER_NAME)
+        == "microsoft.agent_framework"
+    )
+
+
 def test_mcp_span_is_seeded_before_export(monkeypatch):
     obs_mod, exporter = _install_fake_observability(monkeypatch)
     util_genai_bridge.apply_util_genai_bridge()