scriptoriumadmin/litellm
1
0
Fork 0
mirror of https://github.com/BerriAI/litellm.git synced 2026-10-05 02:41:56 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 49

style: satisfy the type-discipline budget gate on the streamed-items accumulator

Browse source
This commit is contained in:
rain 2026-09-15 01:44:31 +08:00 • committed by Rainmemery
parent 7c568dd6c3
commit 60261b48dc
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
litellm/responses/streaming_iterator.py
View file

@ -296,7 +296,7 @@ class BaseResponsesAPIStreamingIterator:
# output_item.done events seen during the stream, keyed by output_index.
# Some providers emit a terminal response.completed event with an empty
# output array even though items were streamed; these are used to rebuild it.
self._streamed_output_items: dict[int, object] = {}
self._streamed_output_items: dict[int, object] = {} # mutable-ok: streaming accumulator keyed by output_index
self._stream_created_time: float = time.time()
# track request context for hooks
@ -522,15 +522,17 @@ class BaseResponsesAPIStreamingIterator:
self._handle_failure(e)
raise
def get_streamed_output_items(self) -> list[object]:
def get_streamed_output_items(self) -> list[object]: # mutable-ok: response.output takes a real list
"""
Output items received via response.output_item.done events, ordered by output_index.
Used to rebuild a terminal response.completed payload whose output array is empty.
"""
if not self._streamed_output_items:
return []
return [item for _, item in sorted(self._streamed_output_items.items())]
return [] # mutable-ok: response.output takes a real list
return [
item for _, item in sorted(self._streamed_output_items.items())
] # mutable-ok: response.output takes a real list
def _log_completed_response(self, *, is_async: bool) -> None:
if self._completed_response_logged: