Merge pull request #77 from scaleapi/jason/fixes-oai

Adding openai fixes

Author: jasonyang101

examples/tutorials/10_agentic/10_temporal/000_hello_acp/project/run_worker.py

@@ -6,7 +6,7 @@
 from agentex.lib.utils.debug import setup_debug_if_enabled
 from agentex.lib.environment_variables import EnvironmentVariables
 
-from workflow import At000HelloAcpWorkflow
+from project.workflow import At000HelloAcpWorkflow
 
 
 

examples/tutorials/10_agentic/10_temporal/010_agent_chat/project/run_worker.py

@@ -6,7 +6,7 @@
 from agentex.lib.utils.debug import setup_debug_if_enabled
 from agentex.lib.environment_variables import EnvironmentVariables
 
-from workflow import At010AgentChatWorkflow
+from project.workflow import At010AgentChatWorkflow
 
 
 

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/run_worker.py

@@ -6,7 +6,7 @@
 from agentex.lib.utils.debug import setup_debug_if_enabled
 from agentex.lib.environment_variables import EnvironmentVariables
 
-from workflow import At020StateMachineWorkflow
+from project.workflow import At020StateMachineWorkflow
 
 
 environment_variables = EnvironmentVariables.refresh()

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/workflow.py

@@ -12,10 +12,10 @@
 from agentex.lib.environment_variables import EnvironmentVariables
 from agentex.lib.sdk.state_machine.state import State
 
-from state_machines.deep_research import DeepResearchStateMachine, DeepResearchState, DeepResearchData
-from workflows.deep_research.clarify_user_query import ClarifyUserQueryWorkflow
-from workflows.deep_research.waiting_for_user_input import WaitingForUserInputWorkflow
-from workflows.deep_research.performing_deep_research import PerformingDeepResearchWorkflow
+from project.state_machines.deep_research import DeepResearchStateMachine, DeepResearchState, DeepResearchData
+from project.workflows.deep_research.clarify_user_query import ClarifyUserQueryWorkflow
+from project.workflows.deep_research.waiting_for_user_input import WaitingForUserInputWorkflow
+from project.workflows.deep_research.performing_deep_research import PerformingDeepResearchWorkflow
 
 environment_variables = EnvironmentVariables.refresh()
 

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/workflows/deep_research/clarify_user_query.py

@@ -6,7 +6,7 @@
 from agentex.lib.types.llm_messages import LLMConfig, SystemMessage, UserMessage
 from agentex.lib.utils.logging import make_logger
 
-from state_machines.deep_research import DeepResearchData, DeepResearchState
+from project.state_machines.deep_research import DeepResearchData, DeepResearchState
 
 logger = make_logger(__name__)
 

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/workflows/deep_research/performing_deep_research.py

@@ -10,7 +10,7 @@
 from agentex.types.text_content import TextContent
 from agentex.lib.utils.logging import make_logger
 
-from state_machines.deep_research import DeepResearchData, DeepResearchState
+from project.state_machines.deep_research import DeepResearchData, DeepResearchState
 
 logger = make_logger(__name__)
 

examples/tutorials/10_agentic/10_temporal/020_state_machine/project/workflows/deep_research/waiting_for_user_input.py

@@ -2,7 +2,7 @@
 from agentex.lib.sdk.state_machine import StateWorkflow, StateMachine
 from agentex.lib.utils.logging import make_logger
 from temporalio import workflow
-from state_machines.deep_research import DeepResearchData, DeepResearchState
+from project.state_machines.deep_research import DeepResearchData, DeepResearchState
 
 logger = make_logger(__name__)
 

pyproject.toml

@@ -32,7 +32,7 @@ dependencies = [
     "jinja2>=3.1.3,<4",
     "mcp[cli]>=1.4.1",
     "scale-gp>=0.1.0a59",
-    "openai-agents>=0.0.7,!=0.2.3", # 0.2.3 bug - https://github.com/openai/openai-agents-python/issues/1276
+    "openai-agents==0.2.7", # 0.2.3 bug - https://github.com/openai/openai-agents-python/issues/1276
     "tzlocal>=5.3.1",
     "tzdata>=2025.2",
     "pytest>=8.4.0",

src/agentex/lib/cli/handlers/run_handlers.py

@@ -89,14 +89,13 @@ async def start_temporal_worker_with_reload(
     worker_path: Path, env: dict[str, str], process_manager: ProcessManager, manifest_dir: Path
 ) -> asyncio.Task[None]:
     """Start temporal worker with auto-reload using watchfiles"""
-    
     try:
         from watchfiles import awatch
     except ImportError:
         console.print("[yellow]watchfiles not installed, falling back to basic worker start[/yellow]")
         console.print("[dim]Install with: pip install watchfiles[/dim]")
         # Fallback to regular worker without reload
-        worker_process = await start_temporal_worker(worker_path, env)
+        worker_process = await start_temporal_worker(worker_path, env, manifest_dir)
         process_manager.add_process(worker_process)
         return asyncio.create_task(stream_process_output(worker_process, "WORKER"))
 
@@ -114,6 +113,7 @@ async def start_worker() -> asyncio.subprocess.Process:
                 # Extract agent name from worker path for cleanup
 
                 agent_name = env.get("AGENT_NAME")
+                console.print(f"FOUND AGENT_NAME FROM ENV VARS: {agent_name} {agent_name is None}")
                 if agent_name is None:
                     agent_name = worker_path.parent.parent.name
 
@@ -150,12 +150,12 @@ async def start_worker() -> asyncio.subprocess.Process:
 
         try:
             # Start initial worker
-            await start_worker()
+            current_process = await start_worker()
             if current_process:
                 output_task = asyncio.create_task(stream_process_output(current_process, "WORKER"))
 
             # Watch for file changes
-            async for changes in awatch(worker_path.parent):
+            async for changes in awatch(manifest_dir, recursive=True):
                 # Filter for Python files
                 py_changes = [(change, path) for change, path in changes if str(path).endswith('.py')]
 
@@ -225,7 +225,9 @@ async def start_temporal_worker(
     worker_path: Path, env: dict[str, str], manifest_dir: Path
 ) -> asyncio.subprocess.Process:
     """Start the temporal worker process"""
-    cmd = [sys.executable, "-m", "run_worker"]
+    run_worker_target = calculate_uvicorn_target_for_local(worker_path, manifest_dir)
+
+    cmd = [sys.executable, "-m", run_worker_target]
 
     console.print(f"[blue]Starting Temporal worker from {worker_path}...[/blue]")
 

src/agentex/lib/core/services/adk/providers/openai.py

@@ -656,7 +656,7 @@ async def run_agent_streamed_auto_send(
                                 reasoning_content = ReasoningContent(
                                     author="agent",
                                     summary=[summary.text for summary in reasoning_item.summary],
-                                    content=[content.text for content in reasoning_item.content] if reasoning_item.content else None,
+                                    content=[content.text for content in reasoning_item.content] if hasattr(reasoning_item, "content") else None,
                                 )
 
                                 # Create reasoning content using streaming context (immediate completion)