Small fix

Author: danielmillerp

src/agentex/lib/core/temporal/plugins/openai_agents/streaming_model.py

@@ -116,10 +116,18 @@ def _prepare_response_input(self, input: Union[str, list[TResponseInputItem]]) -
                     for content_item in content_list:
                         if isinstance(content_item, dict):
                             if content_item.get("type") == "output_text":
-                                content_array.append({
-                                    "type": "input_text",
-                                    "text": content_item.get("text", "")
-                                })
+                                # For assistant messages, keep as output_text
+                                # For user messages, convert to input_text
+                                if role == "user":
+                                    content_array.append({
+                                        "type": "input_text",
+                                        "text": content_item.get("text", "")
+                                    })
+                                else:
+                                    content_array.append({
+                                        "type": "output_text",
+                                        "text": content_item.get("text", "")
+                                    })
                             else:
                                 content_array.append(content_item)