Add af extension

Author: Jimh333

libraries/microsoft-agents-a365-observability-extensions-agentframework/README.md

@@ -0,0 +1 @@
+# Copyright (c) Microsoft. All rights reserved.

libraries/microsoft-agents-a365-observability-extensions-agentframework/microsoft_agents_a365/observability/extensions/agentframework/__init__.py

@@ -0,0 +1,36 @@
+# Copyright (c) Microsoft. All rights reserved.
+
+# Custom Span Processor
+
+from opentelemetry.sdk.trace.export import SpanProcessor
+
+from microsoft_agents_a365.observability.core.constants import GEN_AI_OPERATION_NAME_KEY
+from microsoft_agents_a365.observability.core.inference_operation_type import InferenceOperationType
+from microsoft_agents_a365.observability.core.wrappers.utils import extract_model_name
+
+
+class AgentFrameworkSpanProcessor(SpanProcessor):
+    """
+    SpanProcessor for Agent Framework.
+    """
+
+    def __init__(self, service_name: str | None = None):
+        self.service_name = service_name
+
+    def on_start(self, span, parent_context):
+        pass
+
+    def on_end(self, span, parent_context):
+            EXECUTE_TOOL_OPERATION = "execute_tool"
+            TOOL_CALL_RESULT_TAG = "gen_ai.tool.call.result"
+            EVENT_CONTENT_TAG = "gen_ai.event.content"
+            if hasattr(span, "attributes"):
+                operation_name = span.attributes.get(GEN_AI_OPERATION_NAME_KEY)
+                if isinstance(operation_name, str) and operation_name == EXECUTE_TOOL_OPERATION:
+                    tool_call_result = span.attributes.get(TOOL_CALL_RESULT_TAG)
+                    if tool_call_result is not None:
+                        span.set_attribute(EVENT_CONTENT_TAG, tool_call_result)
+
+            
+
+            

libraries/microsoft-agents-a365-observability-extensions-agentframework/microsoft_agents_a365/observability/extensions/agentframework/span_processor.py

@@ -0,0 +1,48 @@
+# Copyright (c) Microsoft. All rights reserved.
+
+from __future__ import annotations
+
+from collections.abc import Collection
+from typing import Any
+
+from microsoft_agents_a365.observability.core.config import get_tracer_provider, is_configured
+from opentelemetry.instrumentation.instrumentor import BaseInstrumentor
+
+from microsoft_agents_a365.observability.extensions.agentframework.span_processor import (
+    AgentFrameworkSpanProcessor,
+)
+
+# -----------------------------
+# 3) The Instrumentor class
+# -----------------------------
+_instruments = ("semantic-kernel >= 1.0.0",)
+
+
+class AgentFrameworkInstrumentor(BaseInstrumentor):
+    """
+    Instruments Agent Framework:
+      • Installs your custom OTel SpanProcessor
+    """
+
+    def __init__(self):
+        if not is_configured():
+            raise RuntimeError(
+                "Agent365 (or your telemetry config) is not initialized. Configure it before instrumenting."
+            )
+        super().__init__()
+
+    def instrumentation_dependencies(self) -> Collection[str]:
+        return _instruments
+
+    def _instrument(self, **kwargs: Any) -> None:
+        """
+        kwargs (all optional):
+        """
+
+        # Ensure we have an SDK TracerProvider
+        provider = get_tracer_provider()
+        self._processor = AgentFrameworkSpanProcessor()
+        provider.add_span_processor(self._processor)
+
+    def _uninstrument(self, **kwargs: Any) -> None:
+        pass

libraries/microsoft-agents-a365-observability-extensions-agentframework/microsoft_agents_a365/observability/extensions/agentframework/trace_instrumentor.py

@@ -0,0 +1,75 @@
+[build-system]
+requires = ["setuptools>=68", "wheel", "tzdata"]
+build-backend = "setuptools.build_meta"
+
+[project]
+name = "microsoft-agents-a365-observability-extensions-agent-framework"
+dynamic = ["version"]
+authors = [
+    { name = "Microsoft", email = "support@microsoft.com" },
+]
+description = "Agent Framwork observability and tracing extensions for Microsoft Agents A365"
+readme = "README.md"
+requires-python = ">=3.11"
+classifiers = [
+    "Development Status :: 3 - Alpha",
+    "Intended Audience :: Developers",
+    "Programming Language :: Python :: 3",
+    "Programming Language :: Python :: 3.11",
+    "Programming Language :: Python :: 3.12",
+    "Operating System :: OS Independent",
+    "Topic :: Software Development :: Libraries :: Python Modules",
+    "Topic :: Scientific/Engineering :: Artificial Intelligence",
+    "Topic :: System :: Monitoring",
+]
+license = "MIT"
+keywords = ["observability", "telemetry", "tracing", "opentelemetry", "agent-framework", "agents", "ai"]
+dependencies = [
+    "microsoft-agents-a365-observability-core >= 2025.10.16",
+    "opentelemetry-api >= 1.36.0",
+    "opentelemetry-sdk >= 1.36.0",
+    "opentelemetry-instrumentation >= 0.47b0",
+]
+
+[project.urls]
+Homepage = "https://github.com/microsoft/Agent365"
+Repository = "https://github.com/microsoft/Agent365"
+Issues = "https://github.com/microsoft/Agent365/issues"
+Documentation = "https://github.com/microsoft/Agent365-python/tree/main/libraries/microsoft-agents-a365-observability-extensions-agentframework"
+
+[project.optional-dependencies]
+dev = [
+    "pytest >= 7.0.0",
+    "pytest-asyncio >= 0.21.0",
+    "ruff >= 0.1.0",
+    "black >= 23.0.0",
+    "mypy >= 1.0.0",
+]
+test = [
+    "pytest >= 7.0.0",
+    "pytest-asyncio >= 0.21.0",
+]
+
+[tool.setuptools.packages.find]
+where = ["."]
+
+[tool.setuptools]
+license-files = ["../../LICENSE"]
+include-package-data = true
+
+[tool.setuptools.package-data]
+"*" = ["../../LICENSE"]
+
+[tool.black]
+line-length = 100
+target-version = ['py311']
+
+[tool.ruff]
+line-length = 100
+target-version = "py311"
+
+[tool.mypy]
+python_version = "3.11"
+strict = true
+warn_return_any = true
+warn_unused_configs = true

libraries/microsoft-agents-a365-observability-extensions-agentframework/pyproject.toml

@@ -0,0 +1,30 @@
+# Copyright (c) Microsoft. All rights reserved.
+
+import os
+from datetime import datetime
+from zoneinfo import ZoneInfo
+
+from setuptools import setup
+
+
+def build_version():
+    """
+    Example: 2025.10.3+preview.65532  (PEP 440 compliant; avoids hyphens)
+    Uses UTC.
+    """
+
+    if defined_version := os.getenv("A365_SDK_VERSION"):
+        return defined_version  # For CI/CD to set a specific version.
+
+    today = datetime.now(ZoneInfo("UTC"))
+
+    return (
+        f"{today.year}.{today.month}.{today.day}+preview.{today.hour}{today.minute}{today.second}"
+    )
+
+
+VERSION = build_version()
+
+setup(
+    version=VERSION,
+)