Use pydantic data converter everywhere

Author: dandavison

README.md

@@ -121,12 +121,17 @@ temporal operator nexus endpoint create \
 import asyncio
 
 from temporalio.client import Client
+from temporalio.contrib.pydantic import pydantic_data_converter
 from temporalio.worker import Worker
 from .service_handler import mcp_service_handler, CalculatorHandler
 
 async def main():
     # Connect to Temporal (replace host and namespace as needed).
-    client = await Client.connect("localhost:7233", namespace="my-handler-namespace")
+    client = await Client.connect(
+        "localhost:7233",
+        namespace="my-handler-namespace",
+        data_converter=pydantic_data_converter,
+    )
 
     async with Worker(
         client,
@@ -144,12 +149,17 @@ import asyncio
 from mcp.server.lowlevel import NotificationOptions, Server
 from mcp.server.models import InitializationOptions
 from temporalio.client import Client
+from temporalio.contrib.pydantic import pydantic_data_converter
 from nexusmcp import InboundGateway
 
 async def main():
     server = Server("nexus-mcp-demo")
     # Connect to Temporal (replace host and namespace as needed).
-    client = await Client.connect("localhost:7233", namespace="my-caller-namespace")
+    client = await Client.connect(
+        "localhost:7233",
+        namespace="my-caller-namespace",
+        data_converter=pydantic_data_converter,
+    )
 
     # Create the MCP gateway
     gateway = InboundGateway(

tests/test_inbound_gateway.py

@@ -1,13 +1,14 @@
 import asyncio
 
 import anyio
-from mcp.shared.message import SessionMessage
 import pytest
 from mcp import ClientSession
 from mcp.server.lowlevel import NotificationOptions, Server
 from mcp.server.models import InitializationOptions
+from mcp.shared.message import SessionMessage
 from temporalio.api.nexus.v1 import EndpointSpec, EndpointTarget
 from temporalio.api.operatorservice.v1 import CreateNexusEndpointRequest
+from temporalio.contrib.pydantic import pydantic_data_converter
 from temporalio.testing import WorkflowEnvironment
 from temporalio.worker import Worker
 
@@ -23,7 +24,7 @@ async def test_inbound_gateway() -> None:
     endpoint_name = "endpoint"
     task_queue = "handler-queue"
 
-    async with await WorkflowEnvironment.start_local() as env:
+    async with await WorkflowEnvironment.start_local(data_converter=pydantic_data_converter) as env:
         await env.client.operator_service.create_nexus_endpoint(
             CreateNexusEndpointRequest(
                 spec=EndpointSpec(