[codex] Skip parsing incomplete response text

src/openai/lib/_parsing/_responses.py

@@ -71,7 +71,9 @@ def parse_response(
                         type_=ParsedResponseOutputText[TextFormatT],
                         value={
                             **item.to_dict(),
-                            "parsed": parse_text(item.text, text_format=text_format),
+                            "parsed": parse_text(item.text, text_format=text_format)
+                            if output.status == "completed"
+                            else None,
                         },
                     )
                 )

tests/lib/responses/test_responses.py

@@ -4,10 +4,14 @@
 
 import pytest
 from respx import MockRouter
+from pydantic import BaseModel
 from inline_snapshot import snapshot
 
 from openai import OpenAI, AsyncOpenAI
 from openai._utils import assert_signatures_in_sync
+from openai._models import construct_type_unchecked
+from openai.types.responses import Response
+from openai.lib._parsing._responses import parse_response
 
 from ...conftest import base_url
 from ..snapshots import make_snapshot_request
@@ -41,6 +45,52 @@ def test_output_text(client: OpenAI, respx_mock: MockRouter) -> None:
     )
 
 
+def test_parse_incomplete_output_text() -> None:
+    class CalendarEvent(BaseModel):
+        name: str
+
+    content_item: dict[str, object] = {
+        "type": "output_text",
+        "text": '{"name":',
+        "annotations": [],
+        "logprobs": [],
+    }
+    output_item: dict[str, object] = {
+        "id": "msg_123",
+        "type": "message",
+        "role": "assistant",
+        "status": "incomplete",
+        "content": [content_item],
+    }
+    response_payload: dict[str, object] = {
+        "id": "resp_123",
+        "object": "response",
+        "created_at": 0,
+        "model": "gpt-4o-mini",
+        "output": [output_item],
+        "parallel_tool_calls": True,
+        "tool_choice": "auto",
+        "tools": [],
+    }
+    response = construct_type_unchecked(
+        type_=Response,
+        value=response_payload,
+    )
+
+    parsed = parse_response(text_format=CalendarEvent, input_tools=None, response=response)
+
+    assert parsed.output_parsed is None
+
+    output = parsed.output[0]
+    assert output.type == "message"
+    assert output.status == "incomplete"
+
+    content = output.content[0]
+    assert content.type == "output_text"
+    assert content.text == '{"name":'
+    assert content.parsed is None
+
+
 @pytest.mark.parametrize("sync", [True, False], ids=["sync", "async"])
 def test_stream_method_definition_in_sync(sync: bool, client: OpenAI, async_client: AsyncOpenAI) -> None:
     checking_client: OpenAI | AsyncOpenAI = client if sync else async_client