Skip to content

Commit e542e22

Browse files
committed
Update mock_server.py
1 parent d9f7e21 commit e542e22

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

tests/mock_server.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -177,10 +177,12 @@ async def generate(self, req_data: GenerationRequest, initial_request_id: str):
177177
# Fetch raw response for headers in stream mode (awaited)
178178
raw_resp = await self.client.chat.completions.with_raw_response.create(**openai_params)
179179
trace_id = raw_resp.headers.get("X-SiliconCloud-Trace-Id", initial_request_id)
180+
180181
# raw_resp.parse() returns the AsyncStream
181182
return StreamingResponse(
182183
self._stream_generator(raw_resp.parse(), trace_id),
183-
media_type="text/event-stream"
184+
media_type="text/event-stream",
185+
headers={"X-SiliconCloud-Trace-Id": trace_id} # <--- Added Header Propagation
184186
)
185187
else:
186188
# Standard response (awaited)
@@ -265,7 +267,11 @@ def _format_unary_response(self, completion, request_id: str):
265267
"usage": usage_data,
266268
"request_id": request_id
267269
}
268-
return JSONResponse(content=response_body)
270+
271+
return JSONResponse(
272+
content=response_body,
273+
headers={"X-SiliconCloud-Trace-Id": request_id}
274+
)
269275

270276
# --- [FastAPI App & Lifecycle] ---
271277

0 commit comments

Comments
 (0)