switch to plugins on the runners

Author: jssmith

openai_agents/run_agents_as_tools_workflow.py

@@ -1,7 +1,7 @@
 import asyncio
 
 from temporalio.client import Client
-from temporalio.contrib.pydantic import pydantic_data_converter
+from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
 
 from openai_agents.workflows.agents_as_tools_workflow import AgentsAsToolsWorkflow
 
@@ -10,7 +10,9 @@ async def main():
     # Create client connected to server at the given address
     client = await Client.connect(
         "localhost:7233",
-        data_converter=pydantic_data_converter,
+        plugins=[
+            OpenAIAgentsPlugin(),
+        ],
     )
 
     # Execute a workflow

openai_agents/run_customer_service_client.py

@@ -7,7 +7,7 @@
     WorkflowUpdateFailedError,
 )
 from temporalio.common import QueryRejectCondition
-from temporalio.contrib.pydantic import pydantic_data_converter
+from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
 from temporalio.service import RPCError, RPCStatusCode
 
 from openai_agents.workflows.customer_service_workflow import (
@@ -24,7 +24,9 @@ async def main():
     # Create client connected to server at the given address
     client = await Client.connect(
         "localhost:7233",
-        data_converter=pydantic_data_converter,
+        plugins=[
+            OpenAIAgentsPlugin(),
+        ],
     )
 
     handle = client.get_workflow_handle(args.conversation_id)

openai_agents/run_hello_world_workflow.py

@@ -1,7 +1,7 @@
 import asyncio
 
 from temporalio.client import Client
-from temporalio.contrib.pydantic import pydantic_data_converter
+from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
 
 from openai_agents.workflows.hello_world_workflow import HelloWorldAgent
 
@@ -10,7 +10,9 @@ async def main():
     # Create client connected to server at the given address
     client = await Client.connect(
         "localhost:7233",
-        data_converter=pydantic_data_converter,
+        plugins=[
+            OpenAIAgentsPlugin(),
+        ],
     )
 
     # Execute a workflow

openai_agents/run_research_workflow.py

@@ -1,7 +1,7 @@
 import asyncio
 
 from temporalio.client import Client
-from temporalio.contrib.pydantic import pydantic_data_converter
+from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
 
 from openai_agents.workflows.research_bot_workflow import ResearchWorkflow
 
@@ -10,7 +10,9 @@ async def main():
     # Create client connected to server at the given address
     client = await Client.connect(
         "localhost:7233",
-        data_converter=pydantic_data_converter,
+        plugins=[
+            OpenAIAgentsPlugin(),
+        ],
     )
 
     # Execute a workflow

openai_agents/run_tools_workflow.py

@@ -1,7 +1,7 @@
 import asyncio
 
 from temporalio.client import Client
-from temporalio.contrib.pydantic import pydantic_data_converter
+from temporalio.contrib.openai_agents import OpenAIAgentsPlugin
 
 from openai_agents.workflows.tools_workflow import ToolsWorkflow
 
@@ -10,7 +10,9 @@ async def main():
     # Create client connected to server at the given address
     client = await Client.connect(
         "localhost:7233",
-        data_converter=pydantic_data_converter,
+        plugins=[
+            OpenAIAgentsPlugin(),
+        ],
     )
 
     # Execute a workflow