Fix OCI streaming (#13437)

* add oci models to model_prices_and_context_window.json

* remove unsupported and unavailable oci models from docs

* fix: split data chunks when using async streaming

* add oci models to model_prices_and_context_window.json

* fix: split data chunks when using async streaming

* revert model.json modifications
This commit is contained in:
breno-aumo 2025-08-11 22:04:58 -03:00 • committed by GitHub
parent 49ca4dc792
commit 7484a19edf
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -2,7 +2,7 @@ import base64
import datetime
import hashlib
import json
from typing import TYPE_CHECKING, Any, Dict, List, Optional, Tuple, Union
from typing import TYPE_CHECKING, Any, AsyncIterator, Dict, List, Optional, Tuple, Union
from urllib.parse import urlparse
import httpx
@ -586,8 +586,15 @@ class OCIChatConfig(BaseConfig):
completion_stream = response.aiter_text()
async def split_chunks(completion_stream: AsyncIterator[str]):
async for item in completion_stream:
for chunk in item.split("\n\n"):
if not chunk:
continue
yield chunk.strip()
streaming_response = OCIStreamWrapper(
completion_stream=completion_stream,
completion_stream=split_chunks(completion_stream),
model=model,
custom_llm_provider=custom_llm_provider,
logging_obj=logging_obj,