Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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

Expand Down
3 changes: 2 additions & 1 deletion src/agentex/lib/core/clients/temporal/utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down Expand Up @@ -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 [])
)
Expand Down
33 changes: 32 additions & 1 deletion uv.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading