minor change

Author: AlexLu2016

libraries/microsoft-agents-a365-observability-core/microsoft_agents_a365/observability/core/exporters/agent365_exporter.py

@@ -19,7 +19,6 @@
 
 from .utils import (
     DEFAULT_MAX_PAYLOAD_BYTES,
-    INFERENCE_OPERATION_TYPE_NAMES,
     build_export_url,
     chunk_by_size,
     estimate_span_bytes,
@@ -83,8 +82,8 @@ def export(self, spans: Sequence[ReadableSpan]) -> SpanExportResult:
         try:
             groups = filter_and_partition_by_identity(spans)
             if not groups:
-                # No spans with identity; treat as success
-                logger.info("No spans with tenant/agent identity found; nothing exported.")
+                # No eligible genAI spans to export after filtering/partitioning; treat as success
+                logger.info("No eligible genAI spans to export; nothing exported.")
                 return SpanExportResult.SUCCESS
 
             # Log number of groups and total span count

libraries/microsoft-agents-a365-observability-core/microsoft_agents_a365/observability/core/exporters/utils.py

@@ -175,13 +175,15 @@ def filter_and_partition_by_identity(
 
     if non_gen_ai_count > 0:
         logger.debug(
-            f"[Agent365Exporter] {non_gen_ai_count} spans without an eligible "
-            "gen_ai.operation.name filtered out"
+            "[Agent365Exporter] %d spans without an eligible "
+            "gen_ai.operation.name filtered out",
+            non_gen_ai_count,
         )
     if missing_identity_count > 0:
         logger.debug(
-            f"[Agent365Exporter] {missing_identity_count} spans skipped due to "
-            "missing tenant or agent ID"
+            "[Agent365Exporter] %d spans skipped due to "
+            "missing tenant or agent ID",
+            missing_identity_count,
         )
     return groups
 

tests/observability/core/exporters/test_payload_chunking.py

@@ -10,7 +10,9 @@
 from unittest.mock import Mock, patch
 
 from microsoft_agents_a365.observability.core.constants import (
+    CHAT_OPERATION_NAME,
     GEN_AI_AGENT_ID_KEY,
+    GEN_AI_OPERATION_NAME_KEY,
     TENANT_ID_KEY,
 )
 from microsoft_agents_a365.observability.core.exporters.agent365_exporter import (
@@ -165,6 +167,7 @@ def _make_span(self, span_id: int, attribute_size: int) -> ReadableSpan:
         mock_span.attributes = {
             TENANT_ID_KEY: "tenant-1",
             GEN_AI_AGENT_ID_KEY: "agent-1",
+            GEN_AI_OPERATION_NAME_KEY: CHAT_OPERATION_NAME,
             "payload": "x" * attribute_size,
         }
         mock_span.events = []

tests/observability/core/test_agent365_exporter.py

@@ -720,7 +720,7 @@ def test_export_includes_inference_operation_type_chat_spans(self):
             spans_out = request_data["resourceSpans"][0]["scopeSpans"][0]["spans"]
             self.assertEqual(len(spans_out), 1)
             # Value is preserved as-is; no normalization
-            self.assertEqual(spans_out[0]["attributes"]["gen_ai.operation.name"], "Chat")
+            self.assertEqual(spans_out[0]["attributes"][GEN_AI_OPERATION_NAME_KEY], "Chat")
 
     def test_export_filters_out_unsupported_inference_operation_types(self):
         """Spans with TextCompletion / GenerateContent are filtered out."""
@@ -754,7 +754,7 @@ def test_export_does_not_normalize_canonical_operation_names(self):
                     _, body, _ = mock_post.call_args[0]
                     request_data = json.loads(body)
                     span_out = request_data["resourceSpans"][0]["scopeSpans"][0]["spans"][0]
-                    self.assertEqual(span_out["attributes"]["gen_ai.operation.name"], op)
+                    self.assertEqual(span_out["attributes"][GEN_AI_OPERATION_NAME_KEY], op)
 
 
 if __name__ == "__main__":