Spaces:
Running
Running
Update gen.py
Browse files
gen.py
CHANGED
|
@@ -1237,7 +1237,17 @@ async def create_response(
|
|
| 1237 |
|
| 1238 |
if sent_created and not completed:
|
| 1239 |
print("[RESPONSES STREAM] guard firing — upstream closed without [DONE]")
|
| 1240 |
-
done_event = json.dumps({
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 1241 |
yield f"data: {done_event}\n\n"
|
| 1242 |
|
| 1243 |
return StreamingResponse(
|
|
|
|
| 1237 |
|
| 1238 |
if sent_created and not completed:
|
| 1239 |
print("[RESPONSES STREAM] guard firing — upstream closed without [DONE]")
|
| 1240 |
+
done_event = json.dumps({
|
| 1241 |
+
"type": "response.completed",
|
| 1242 |
+
"response": {
|
| 1243 |
+
"id": response_id,
|
| 1244 |
+
"object": "response",
|
| 1245 |
+
"model": model_label,
|
| 1246 |
+
"status": "completed",
|
| 1247 |
+
"output": [],
|
| 1248 |
+
"usage": None,
|
| 1249 |
+
},
|
| 1250 |
+
})
|
| 1251 |
yield f"data: {done_event}\n\n"
|
| 1252 |
|
| 1253 |
return StreamingResponse(
|