replace local adapters with python sdk

Author: jssmith

openai_agents/adapters/__init__.py openai_agents/__init__.pyopenai_agents/adapters/__init__.py renamed to openai_agents/__init__.py

@@ -6,7 +6,6 @@
 from temporalio.common import WorkflowIDReusePolicy, QueryRejectCondition
 from temporalio.service import RPCError, RPCStatusCode
 
-from openai_agents.adapters.open_ai_converter import open_ai_data_converter
 from openai_agents.workflows.customer_service_workflow import CustomerServiceWorkflow, ProcessUserMessageInput
 
 
@@ -16,7 +15,7 @@ async def main():
     args = parser.parse_args()
 
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233", data_converter=open_ai_data_converter)
+    client = await Client.connect("localhost:7233")
 
     handle = client.get_workflow_handle(args.conversation_id)
 

openai_agents/adapters/_heartbeat_decorator.py

@@ -3,13 +3,13 @@
 from temporalio.client import Client
 from temporalio.common import WorkflowIDReusePolicy
 
-from openai_agents.adapters.open_ai_converter import open_ai_data_converter
+# from openai_agents.adapters.open_ai_converter import open_ai_data_converter
 from openai_agents.workflows.agents_as_tools_workflow import AgentsAsToolsWorkflow
 
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233", data_converter=open_ai_data_converter)
+    client = await Client.connect("localhost:7233")
 
     # Execute a workflow
     result = await client.execute_workflow(AgentsAsToolsWorkflow.run,

openai_agents/adapters/invoke_model_activity.py

@@ -3,22 +3,23 @@
 from temporalio.client import Client
 from temporalio.common import WorkflowIDReusePolicy
 
-from openai_agents.adapters.open_ai_converter import open_ai_data_converter
 from openai_agents.workflows.hello_world_workflow import HelloWorldAgent
 
+from temporalio.contrib.openai_agents.temporal_openai_agents import (
+    set_open_ai_agent_temporal_overrides,
+)
+
 
 async def main():
     # Create client connected to server at the given address
-    client = await Client.connect("localhost:7233",
-                                  data_converter=open_ai_data_converter,
-                                  )
-
-    # Execute a workflow
-    result = await client.execute_workflow(HelloWorldAgent.run, "Tell me about recursion in programming.",
-                                           id="my-workflow-id", task_queue="my-task-queue",
-                                           id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING)
-
-    print(f"Result: {result}")
+    client = await Client.connect("localhost:7233")
+
+    with set_open_ai_agent_temporal_overrides():
+        # Execute a workflow
+        result = await client.execute_workflow(HelloWorldAgent.run, "Tell me about recursion in programming.",
+                                            id="my-workflow-id", task_queue="my-task-queue",
+                                            id_reuse_policy=WorkflowIDReusePolicy.TERMINATE_IF_RUNNING)
+        print(f"Result: {result}")
 
 
 if __name__ == "__main__":

openai_agents/adapters/open_ai_converter.py

@@ -3,15 +3,15 @@
 from temporalio.client import Client
 from temporalio.common import WorkflowIDReusePolicy
 
-from openai_agents.adapters.open_ai_converter import open_ai_data_converter
+# from openai_agents.adapters.open_ai_converter import open_ai_data_converter
 from openai_agents.workflows.research_bot_workflow import ResearchWorkflow
 
 
 async def main():
     # Create client connected to server at the given address
     client = await Client.connect(
         "localhost:7233",
-        data_converter=open_ai_data_converter
+        # data_converter=open_ai_data_converter
     )
 
     # Execute a workflow