cleanup id_reuse_policy and imports

Author: jssmith

openai_agents/run_agents_as_tools_workflow.py

@@ -22,7 +22,6 @@ async def main():
         "Translate to English: '¿Cómo estás?'",
         id="my-workflow-id",
         task_queue="openai-agents-task-queue",
-        id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
 
     print(f"Result: {result}")

openai_agents/run_customer_service_client.py

@@ -51,7 +51,6 @@ async def main():
             CustomerServiceWorkflow.run,
             id=args.conversation_id,
             task_queue="openai-agents-task-queue",
-            id_reuse_policy=WorkflowIDReusePolicy.ALLOW_DUPLICATE,
         )
         history = []
     print(*history, sep="\n")

openai_agents/run_hello_world_workflow.py

@@ -22,7 +22,6 @@ async def main():
         "Tell me about recursion in programming.",
         id="my-workflow-id",
         task_queue="openai-agents-task-queue",
-        id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
     print(f"Result: {result}")
 

openai_agents/run_research_workflow.py

@@ -22,7 +22,6 @@ async def main():
         "Caribbean vacation spots in April, optimizing for surfing, hiking and water sports",
         id="research-workflow",
         task_queue="openai-agents-task-queue",
-        id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
 
     print(f"Result: {result}")

openai_agents/run_tools_workflow.py

@@ -22,7 +22,6 @@ async def main():
         "What is the weather in Tokio?",
         id="tools-workflow",
         task_queue="openai-agents-task-queue",
-        id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
 
     print(f"Result: {result}")

openai_agents/run_worker.py

@@ -10,22 +10,17 @@
 from temporalio.contrib.openai_agents.open_ai_data_converter import (
     open_ai_data_converter,
 )
-from temporalio.worker import Worker
-
-with workflow.unsafe.imports_passed_through():
-    from openai_agents.workflows.hello_world_workflow import HelloWorldAgent
-    from openai_agents.workflows.tools_workflow import ToolsWorkflow
-    from openai_agents.workflows.research_bot_workflow import ResearchWorkflow
-    from openai_agents.workflows.customer_service_workflow import (
-        CustomerServiceWorkflow,
-    )
-    from openai_agents.workflows.agents_as_tools_workflow import AgentsAsToolsWorkflow
-
-    from openai_agents.workflows.get_weather_activity import get_weather
-
 from temporalio.contrib.openai_agents.temporal_openai_agents import (
     set_open_ai_agent_temporal_overrides,
 )
+from temporalio.worker import Worker
+
+from openai_agents.workflows.agents_as_tools_workflow import AgentsAsToolsWorkflow
+from openai_agents.workflows.customer_service_workflow import CustomerServiceWorkflow
+from openai_agents.workflows.get_weather_activity import get_weather
+from openai_agents.workflows.hello_world_workflow import HelloWorldAgent
+from openai_agents.workflows.research_bot_workflow import ResearchWorkflow
+from openai_agents.workflows.tools_workflow import ToolsWorkflow
 
 
 async def main():