phoenix/litellm-mirror
0
0
Fork 1
mirror of https://github.com/BerriAI/litellm.git synced 2025-04-25 10:44:24 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

STREAM_SSE_DONE_STRING

Browse source
This commit is contained in:
Ishaan Jaff 2025-03-12 09:33:28 -07:00
parent aa250088b2
commit 58acf23c3e
2 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

1
litellm/constants.py
View file

@ -18,6 +18,7 @@ SINGLE_DEPLOYMENT_TRAFFIC_FAILURE_THRESHOLD = 1000 # Minimum number of requests
REPEATED_STREAMING_CHUNK_LIMIT = 100 # catch if model starts looping the same chunk while streaming. Uses high default to prevent false positives.
#### Networking settings ####
request_timeout: float = 6000 # time in seconds
STREAM_SSE_DONE_STRING: str = "[DONE]"
LITELLM_CHAT_PROVIDERS = [
"openai",

6
litellm/responses/streaming_iterator.py
View file

@ -5,17 +5,15 @@ from typing import Any, AsyncIterator, Dict, Optional, Union
import httpx
from litellm.constants import STREAM_SSE_DONE_STRING
from litellm.litellm_core_utils.litellm_logging import Logging as LiteLLMLoggingObj
from litellm.llms.base_llm.responses.transformation import BaseResponsesAPIConfig
from litellm.types.llms.openai import (
ResponsesAPIResponse,
ResponsesAPIStreamEvents,
ResponsesAPIStreamingResponse,
)
from litellm.utils import CustomStreamWrapper
COMPLETED_OPENAI_CHUNK_TYPE = "response.completed"
class BaseResponsesAPIStreamingIterator:
"""
@ -50,7 +48,7 @@ class BaseResponsesAPIStreamingIterator:
return None
# Handle "[DONE]" marker
if chunk == "[DONE]":
if chunk == STREAM_SSE_DONE_STRING:
self.finished = True
return None