(sse_chunk_dicts)
| 58 | raise_request_validation_error(f"Model {model.model_id} does not support streaming.") |
| 59 | |
| 60 | async def generator(sse_chunk_dicts): |
| 61 | async for chunk_dict in sse_chunk_dicts: |
| 62 | yield f"data: {json.dumps(chunk_dict)}\n\n" |
| 63 | yield SSE_DONE_MSG |
| 64 | |
| 65 | sse_chunk_dicts = await stream_chat_completion( |
| 66 | model=model, |
no outgoing calls
no test coverage detected