update tasks queues and executor

Author: jssmith

openai_agents/run_agents_as_tools_workflow.py

@@ -21,7 +21,7 @@ async def main():
         AgentsAsToolsWorkflow.run,
         "Translate to English: '¿Cómo estás?'",
         id="my-workflow-id",
-        task_queue="my-task-queue",
+        task_queue="openai-agents-task-queue",
         id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
 

openai_agents/run_customer_service_client.py

@@ -50,7 +50,7 @@ async def main():
         await client.start_workflow(
             CustomerServiceWorkflow.run,
             id=args.conversation_id,
-            task_queue="my-task-queue",
+            task_queue="openai-agents-task-queue",
             id_reuse_policy=WorkflowIDReusePolicy.ALLOW_DUPLICATE,
         )
         history = []

openai_agents/run_hello_world_workflow.py

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

openai_agents/run_research_workflow.py

@@ -21,7 +21,7 @@ async def main():
         ResearchWorkflow.run,
         "Caribbean vacation spots in April, optimizing for surfing, hiking and water sports",
         id="research-workflow",
-        task_queue="my-task-queue",
+        task_queue="openai-agents-task-queue",
         id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
 

openai_agents/run_tools_workflow.py

@@ -21,7 +21,7 @@ async def main():
         ToolsWorkflow.run,
         "What is the weather in Tokio?",
         id="tools-workflow",
-        task_queue="my-task-queue",
+        task_queue="openai-agents-task-queue",
         id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING,
     )
 

openai_agents/run_worker.py

@@ -39,24 +39,22 @@ async def main():
         )
 
         model_activity = ModelActivity(model_provider=None)
-        with concurrent.futures.ThreadPoolExecutor(max_workers=20) as activity_executor:
-            worker = Worker(
-                client,
-                task_queue="my-task-queue",
-                workflows=[
-                    HelloWorldAgent,
-                    ToolsWorkflow,
-                    ResearchWorkflow,
-                    CustomerServiceWorkflow,
-                    AgentsAsToolsWorkflow,
-                ],
-                activities=[
-                    model_activity.invoke_model_activity,
-                    get_weather,
-                ],
-                activity_executor=activity_executor,
-            )
-            await worker.run()
+        worker = Worker(
+            client,
+            task_queue="openai-agents-task-queue",
+            workflows=[
+                HelloWorldAgent,
+                ToolsWorkflow,
+                ResearchWorkflow,
+                CustomerServiceWorkflow,
+                AgentsAsToolsWorkflow,
+            ],
+            activities=[
+                model_activity.invoke_model_activity,
+                get_weather,
+            ],
+        )
+        await worker.run()
 
 
 if __name__ == "__main__":