brucearctor
diff --git a/‎temporalio/contrib/openai_agents/invoke_model_activity.py‎
Lines changed: 2 additions & 3 deletions b/‎temporalio/contrib/openai_agents/invoke_model_activity.py‎
Lines changed: 2 additions & 3 deletions
diff --git a/‎tests/contrib/openai_agents/test_openai.py‎
Lines changed: 9 additions & 8 deletions b/‎tests/contrib/openai_agents/test_openai.py‎
Lines changed: 9 additions & 8 deletions
@@ -24,6 +24,7 @@
     WebSearchTool,
 )
 from agents.models.multi_provider import MultiProvider
+from pydantic_core import to_jsonable_python
 from typing_extensions import Required, TypedDict
 
 from temporalio import activity, workflow
@@ -137,9 +138,7 @@ async def empty_on_invoke_handoff(
         ) -> Any:
             return None
 
-        # workaround for https://github.com/pydantic/pydantic/issues/9541
-        # ValidatorIterator returned
-        input_json = json.dumps(input["input"], default=str)
+        input_json = json.dumps(to_jsonable_python(input["input"]))
         input_input = json.loads(input_json)
 
         def make_tool(tool: ToolInput) -> Tool:
 
@@ -2,7 +2,7 @@
 import uuid
 from dataclasses import dataclass
 from datetime import timedelta
-from typing import Any, Optional, Union, no_type_check
+from typing import Any, Optional, Union, no_type_check, cast
 
 import pytest
 from pydantic import ConfigDict, Field
@@ -64,8 +64,8 @@
         ResponseFunctionToolCall,
         ResponseFunctionWebSearch,
         ResponseOutputMessage,
-        ResponseOutputText,
-    )
+        ResponseOutputText, EasyInputMessageParam,
+)
     from openai.types.responses.response_function_web_search import ActionSearch
     from openai.types.responses.response_prompt_param import ResponsePromptParam
 
@@ -98,6 +98,7 @@ def __init__(
     ) -> None:
         global response_index
         response_index = 0
+        self.inputs: list[Union[str, list[TResponseInputItem]]] = []
         super().__init__(model, openai_client)
 
     async def get_response(
@@ -115,6 +116,7 @@ async def get_response(
         global response_index
         response = self.responses[response_index]
         response_index += 1
+        self.inputs.append(input)
         return response
 
 
@@ -805,12 +807,11 @@ async def test_agents_as_tools_workflow(client: Client, use_local_model: bool):
 
     model_params = ModelActivityParameters(start_to_close_timeout=timedelta(seconds=30))
     with set_open_ai_agent_temporal_overrides(model_params):
-        model_activity = ModelActivity(
-            TestProvider(
-                AgentAsToolsModel(  # type: ignore
+        model = AgentAsToolsModel(  # type: ignore
                     "", openai_client=AsyncOpenAI(api_key="Fake key")
                 )
-            )
+        model_activity = ModelActivity(
+            TestProvider(model)
             if use_local_model
             else None
         )
@@ -862,7 +863,7 @@ async def test_agents_as_tools_workflow(client: Client, use_local_model: bool):
                     .activity_task_completed_event_attributes.result.payloads[0]
                     .data.decode()
                 )
-
+                assert isinstance(cast(EasyInputMessageParam, model.inputs[3][3])["content"], list)
 
 class AirlineAgentContext(BaseModel):
     passenger_name: Optional[str] = None