fix(streaming): include ModelResponseStream in _extract_usage_chunk annotation

This commit is contained in:
mateo-berri 2026-07-06 17:03:18 +00:00
parent 8a4942340e
commit 21c126464b
No known key found for this signature in database

View file

@ -517,7 +517,7 @@ class ChunkProcessor:
return reasoning_tokens
@staticmethod
def _extract_usage_chunk(chunk: dict[str, Any] | ModelResponse) -> Usage | None:
def _extract_usage_chunk(chunk: dict[str, Any] | ModelResponse | ModelResponseStream) -> Usage | None:
usage_chunk: Usage | dict[str, Any] | None = None
if hasattr(chunk, "usage") and chunk.usage is not None:
usage_chunk = chunk.usage