Feat/310 default agent conf

.github/workflows/build.yaml

@@ -20,10 +20,10 @@ jobs:
     runs-on: ubuntu-latest
     steps:
     - uses: actions/checkout@v6
-    - name: Set up Python 3.10
+    - name: Set up Python 3.11
       uses: actions/setup-python@v6
       with:
-        python-version: "3.10"
+        python-version: "3.11"
     - name: Install dependencies
       run: |
         python -m pip install --upgrade pip
@@ -49,7 +49,7 @@ jobs:
     strategy:
       fail-fast: false
       matrix:
-        python_ver: ["3.10", "3.11", "3.12", "3.13"]
+        python_ver: ["3.11", "3.12", "3.13"]
     steps:
     - uses: actions/checkout@v6
     - name: Set up Python ${{ matrix.python_ver }}

dapr_agents/agents/components.py

@@ -6,9 +6,8 @@
 from datetime import datetime, timezone
 from typing import Any, Callable, Dict, Optional, Sequence
 
-from dapr.clients import DaprClient
 from dapr.clients.grpc._state import Concurrency, Consistency, StateOptions
-from dapr.clients.grpc._response import GetMetadataResponse, RegisteredComponents
+
 from pydantic import BaseModel, ValidationError
 
 from dapr_agents.agents.configs import (
@@ -22,10 +21,10 @@
 from dapr_agents.agents.schemas import AgentWorkflowEntry
 from dapr_agents.storage.daprstores.stateservice import (
     StateStoreError,
-    StateStoreService,
 )
 from dapr_agents.types.workflow import DaprWorkflowStatus
 
+
 logger = logging.getLogger(__name__)
 
 
@@ -68,38 +67,6 @@ def __init__(
         self.name = name
         self._workflow_grpc_options = workflow_grpc_options
 
-        with DaprClient() as _client:
-            resp: GetMetadataResponse = _client.get_metadata()
-            self.appid = resp.application_id
-            if pubsub is None or state is None or registry is None:
-                components: Sequence[RegisteredComponents] = resp.registered_components
-                for component in components:
-                    if (
-                        "state" in component.type
-                        and component.name == "agent-wfstatestore"
-                        and state is None
-                    ):
-                        state = AgentStateConfig(
-                            store=StateStoreService(store_name=component.name),
-                            state_key=f"{name.replace(' ', '-').lower() if name else 'default'}:workflow_state",
-                        )
-                    if component.name == "agent-registry" and registry is None:
-                        registry = AgentRegistryConfig(
-                            store=StateStoreService(store_name="agent-registry"),
-                            team_name="default",
-                        )
-                    if (
-                        "pubsub" in component.type
-                        and component.name == "agent-pubsub"
-                        and pubsub is None
-                    ):
-                        logger.info(f"topic: {name}.topic")
-                        pubsub = AgentPubSubConfig(
-                            pubsub_name="agent-pubsub",
-                            agent_topic=f"{name.replace(' ', '-').lower()}.topic",
-                            broadcast_topic="agents.broadcast",
-                        )
-
         # -----------------------------
         # Pub/Sub configuration (copy)
         # -----------------------------

dapr_agents/agents/configs.py

@@ -1,6 +1,8 @@
 from __future__ import annotations
 
 import re
+from os import getenv
+from enum import StrEnum
 from dataclasses import dataclass, field
 from typing import (
     Any,
@@ -28,6 +30,10 @@ def _ensure_jinja_placeholders(text: str) -> str:
     return _JINJA_PLACEHOLDER_PATTERN.sub(r"{{\1}}", text)
 
 
+def _empty_headers() -> Dict[str, str]:
+    return {}
+
+
 # Type hooks for state customization
 EntryFactory = Callable[..., Any]
 MessageCoercer = Callable[[Dict[str, Any]], Any]
@@ -295,3 +301,96 @@ class WorkflowRetryPolicy:
     max_backoff_seconds: Optional[int] = 30
     backoff_multiplier: Optional[float] = 1.5
     retry_timeout: Optional[Union[int, None]] = None
+
+
+class AgentTracingExporter(StrEnum):
+    """
+    Supported tracing exporters for Dapr Agents observability.
+    """
+
+    OTLP_GRPC = "otlp_grpc"
+    OTLP_HTTP = "otlp_http"
+    ZIPKIN = "zipkin"
+    CONSOLE = "console"
+
+
+class AgentLoggingExporter(StrEnum):
+    """
+    Supported logging exporters for Dapr Agents observability.
+    """
+
+    CONSOLE = "console"
+    OTLP_GRPC = "otlp_grpc"
+    OTLP_HTTP = "otlp_http"
+
+
+@dataclass
+class AgentObservabilityConfig:
+    """
+    Configuration settings for Dapr Agents observability features.
+
+    Attributes:
+        enabled: Enable/Disable observability.
+        headers: Optional headers for observability exporters.
+        auth_token: Optional authentication token for exporters.
+        endpoint: Optional endpoint URL for observability exporters.
+        service_name: Optional service name for observability data.
+        logging_enabled: Enable/disable logging observability.
+        logging_exporter: Logging exporter type.
+        tracing_enabled: Enable/disable tracing observability.
+        tracing_exporter: Tracing exporter type.
+    """
+
+    enabled: Optional[bool] = None
+    headers: Dict[str, str] = field(default_factory=_empty_headers)
+    auth_token: Optional[str] = None
+    endpoint: Optional[str] = None
+    service_name: Optional[str] = None
+    logging_enabled: Optional[bool] = None
+    logging_exporter: Optional[AgentLoggingExporter] = None
+    tracing_enabled: Optional[bool] = None
+    tracing_exporter: Optional[AgentTracingExporter] = None
+
+    @classmethod
+    def from_env(cls) -> "AgentObservabilityConfig":
+        """Create observability config from environment variables."""
+        headers: Dict[str, str] = {}
+        if token := getenv("OTEL_TOKEN"):
+            headers["Authorization"] = token
+
+        logging_exporter: Optional[AgentLoggingExporter] = None
+        if logging_exporter_str := getenv("OTEL_LOGGING_EXPORTER"):
+            try:
+                logging_exporter = AgentLoggingExporter(logging_exporter_str)
+            except (ValueError, KeyError):
+                logging_exporter = AgentLoggingExporter.CONSOLE
+
+        tracing_exporter: Optional[AgentTracingExporter] = None
+        if tracing_exporter_str := getenv("OTEL_TRACING_EXPORTER"):
+            try:
+                tracing_exporter = AgentTracingExporter(tracing_exporter_str)
+            except (ValueError, KeyError):
+                tracing_exporter = AgentTracingExporter.CONSOLE
+
+        enabled: Optional[bool] = None
+        if getenv("OTEL_ENABLED") is not None:
+            enabled = getenv("OTEL_ENABLED", "false").lower() == "true"
+
+        logging_enabled: Optional[bool] = None
+        if getenv("OTEL_LOGGING_ENABLED") is not None:
+            logging_enabled = getenv("OTEL_LOGGING_ENABLED", "false").lower() == "true"
+
+        tracing_enabled: Optional[bool] = None
+        if getenv("OTEL_TRACING_ENABLED") is not None:
+            tracing_enabled = getenv("OTEL_TRACING_ENABLED", "false").lower() == "true"
+
+        return cls(
+            enabled=enabled,
+            headers=headers,
+            endpoint=getenv("OTEL_ENDPOINT"),
+            service_name=getenv("OTEL_SERVICE_NAME"),
+            logging_enabled=logging_enabled,
+            logging_exporter=logging_exporter,
+            tracing_enabled=tracing_enabled,
+            tracing_exporter=tracing_exporter,
+        )

dapr_agents/agents/durable.py

@@ -17,6 +17,7 @@
     AgentStateConfig,
     WorkflowGrpcOptions,
     WorkflowRetryPolicy,
+    AgentObservabilityConfig,
 )
 from dapr_agents.agents.prompting import AgentProfileConfig
 from dapr_agents.agents.schemas import (
@@ -79,6 +80,7 @@ def __init__(
         workflow_grpc: Optional[WorkflowGrpcOptions] = None,
         runtime: Optional[wf.WorkflowRuntime] = None,
         retry_policy: WorkflowRetryPolicy = WorkflowRetryPolicy(),
+        agent_observability: Optional[AgentObservabilityConfig] = None,
     ) -> None:
         """
         Initialize behavior, infrastructure, and workflow runtime.
@@ -108,6 +110,7 @@ def __init__(
             workflow_grpc: Optional gRPC overrides for the workflow runtime channel.
             runtime: Optional pre-existing workflow runtime to attach to.
             retry_policy: Durable retry policy configuration.
+            agent_observability: Observability configuration for tracing/logging.
         """
         super().__init__(
             pubsub=pubsub,
@@ -127,6 +130,7 @@ def __init__(
             llm=llm,
             tools=tools,
             prompt_template=prompt_template,
+            agent_observability=agent_observability,
         )
 
         apply_grpc_options(self.workflow_grpc_options)

dapr_agents/observability/__init__.py

@@ -1,6 +1,5 @@
 from .instrumentor import DaprAgentsInstrumentor
 
-
 __all__ = [
     "DaprAgentsInstrumentor",
 ]