wip

Author: jssmith

openai_agents/mcp/run_file_system_stateful_worker.py

@@ -11,12 +11,16 @@
     OpenAIAgentsPlugin,
     StatefulMCPServer,
 )
+import logging
 from temporalio.worker import Worker
 
 from openai_agents.mcp.workflows.file_system_stateful_workflow import FileSystemWorkflow
 
 
 async def main():
+
+    logging.basicConfig(level=logging.DEBUG)
+    
     current_dir = os.path.dirname(os.path.abspath(__file__))
     samples_dir = os.path.join(current_dir, "sample_files")
 
@@ -53,6 +57,7 @@ async def main():
             # No custom activities needed for these workflows
         ],
     )
+    logging.debug("STARTED WORKER")
     await worker.run()
 
 

openai_agents/mcp/run_file_system_stateful_workflow.py

@@ -6,6 +6,7 @@
 
 from openai_agents.mcp.workflows.file_system_stateful_workflow import FileSystemWorkflow
 
+import uuid
 
 async def main():
     # Create client connected to server at the given address
@@ -19,7 +20,7 @@ async def main():
     # Execute a workflow
     result = await client.execute_workflow(
         FileSystemWorkflow.run,
-        id="file-system-workflow",
+        id=f"file-system-workflow-{uuid.uuid4()}",
         task_queue="openai-agents-mcp-stateful-task-queue",
     )
 

openai_agents/mcp/workflows/file_system_stateful_workflow.py

@@ -13,7 +13,7 @@ class FileSystemWorkflow:
     async def run(self) -> str:
         async with temporal_openai_agents.workflow.stateful_mcp_server(
             "FileSystemServer",
-            workflow.ActivityConfig(start_to_close_timeout=timedelta(seconds=60)),
+            #workflow.ActivityConfig(start_to_close_timeout=timedelta(seconds=120)),
         ) as server:
             with trace(workflow_name="MCP File System Example"):
                 agent = Agent(