Update gen.py

gen.py

@@ -1200,29 +1200,29 @@ async def create_response(
             sent_created = False
             completed = False
             buffer = ""
-
+        
             async for chunk in response.body_iterator:
                 if isinstance(chunk, bytes):
                     chunk = chunk.decode("utf-8", errors="replace")
                 buffer += chunk
-
+        
                 while "\n" in buffer:
                     line, buffer = buffer.split("\n", 1)
                     line = line.rstrip("\r")
                     if not line:
                         continue
-
+        
                     translated, new_sent, is_done = _wrap_responses_stream_chunk(
                         line, response_id, model_label, sent_created
                     )
                     sent_created = new_sent
-
+        
                     if is_done:
                         completed = True
-
+        
                     if translated:
                         yield translated
-
+        
             if buffer.strip():
                 translated, new_sent, is_done = _wrap_responses_stream_chunk(
                     buffer.strip(), response_id, model_label, sent_created
@@ -1232,19 +1232,12 @@ async def create_response(
                     completed = True
                 if translated:
                     yield translated
-
+        
+            print(f"[RESPONSES STREAM] generator exhausted. sent_created={sent_created} completed={completed}")
+        
             if sent_created and not completed:
-                done_event = json.dumps({
-                    "type": "response.completed",
-                    "response": {
-                        "id": response_id,
-                        "object": "response",
-                        "model": model_label,
-                        "status": "completed",
-                        "output": [],
-                        "usage": None,
-                    },
-                })
+                print("[RESPONSES STREAM] guard firing — upstream closed without [DONE]")
+                done_event = json.dumps({...})
                 yield f"data: {done_event}\n\n"
 
         return StreamingResponse(