Merge pull request #290 from scaleapi/dm/fix-sync-openai-agents-template

Fix missing imports in sync-openai-agents template

Author: danielmillerp

pyproject.toml

@@ -49,6 +49,8 @@ dependencies = [
     "claude-agent-sdk>=0.1.0",
     "anthropic>=0.40.0",
     "langgraph-checkpoint>=2.0.0",
+    "opentelemetry-sdk>=1.20.0",
+    "opentelemetry-api>=1.20.0",
 ]
 
 requires-python = ">= 3.12,<4"

src/agentex/lib/cli/templates/sync-openai-agents/project/acp.py.j2

@@ -9,8 +9,9 @@ from agentex.lib.core.tracing.tracing_processor_manager import add_tracing_proce
 from agentex.lib.types.tracing import SGPTracingProcessorConfig
 from agentex.lib.utils.model_utils import BaseModel
 
-from agentex.types.task_message_update import TaskMessageUpdate
+from agentex.types.task_message_update import TaskMessageUpdate, StreamTaskMessageFull
 from agentex.types.task_message_content import TaskMessageContent
+from agentex.types.text_content import TextContent
 from agentex.lib.utils.logging import make_logger
 from agents import Agent, Runner, RunConfig, function_tool
 
@@ -83,6 +84,7 @@ async def handle_message_send(
                 content="Hey, sorry I'm unable to respond to your message because you're running this example without an OpenAI API key. Please set the OPENAI_API_KEY environment variable to run this example. Do this by either by adding a .env file to the project/ directory or by setting the environment variable in your terminal.",
             ),
         )
+        return
 
     user_prompt = params.content.content
 

src/agentex/lib/core/clients/temporal/utils.py

@@ -6,7 +6,6 @@
 from temporalio.worker import Interceptor
 from temporalio.runtime import Runtime, TelemetryConfig, OpenTelemetryConfig
 from temporalio.contrib.pydantic import pydantic_data_converter
-from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
 
 # class DateTimeJSONEncoder(AdvancedJSONEncoder):
 #     def default(self, o: Any) -> Any:
@@ -97,6 +96,8 @@ async def get_temporal_client(temporal_address: str, metrics_url: str | None = N
         validate_client_plugins(plugins)
 
     # Check if OpenAI plugin is present - it needs to configure its own data converter
+    # Lazy import to avoid pulling in opentelemetry.sdk for non-Temporal agents
+    from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
     has_openai_plugin = any(
         isinstance(p, OpenAIAgentsPlugin) for p in (plugins or [])
     )