|
3 | 3 | import asyncio
|
4 | 4 | import base64
|
5 | 5 | import json
|
6 |
| -from collections.abc import AsyncIterator, Awaitable |
| 6 | +from collections.abc import AsyncIterator |
7 | 7 | from contextlib import asynccontextmanager
|
8 | 8 | from dataclasses import dataclass, field
|
9 | 9 | from datetime import datetime
|
@@ -205,7 +205,7 @@ async def request_stream(
|
205 | 205 | check_allow_model_requests()
|
206 | 206 | model_settings = cast(GoogleModelSettings, model_settings or {})
|
207 | 207 | response = await self._generate_content(messages, True, model_settings, model_request_parameters)
|
208 |
| - yield await self._process_streamed_response(response) # type: ignore |
| 208 | + yield await self._process_streamed_response(response) |
209 | 209 |
|
210 | 210 | @property
|
211 | 211 | def model_name(self) -> GoogleModelName:
|
@@ -258,15 +258,15 @@ async def _generate_content(
|
258 | 258 | stream: Literal[True],
|
259 | 259 | model_settings: GoogleModelSettings,
|
260 | 260 | model_request_parameters: ModelRequestParameters,
|
261 |
| - ) -> Awaitable[AsyncIterator[GenerateContentResponse]]: ... |
| 261 | + ) -> AsyncIterator[GenerateContentResponse]: ... |
262 | 262 |
|
263 | 263 | async def _generate_content(
|
264 | 264 | self,
|
265 | 265 | messages: list[ModelMessage],
|
266 | 266 | stream: bool,
|
267 | 267 | model_settings: GoogleModelSettings,
|
268 | 268 | model_request_parameters: ModelRequestParameters,
|
269 |
| - ) -> GenerateContentResponse | Awaitable[AsyncIterator[GenerateContentResponse]]: |
| 269 | + ) -> GenerateContentResponse | AsyncIterator[GenerateContentResponse]: |
270 | 270 | tools = self._get_tools(model_request_parameters)
|
271 | 271 |
|
272 | 272 | response_mime_type = None
|
@@ -324,7 +324,7 @@ async def _generate_content(
|
324 | 324 | json_decode_error = None
|
325 | 325 | for attempt in range(max_attempts):
|
326 | 326 | try:
|
327 |
| - return await func(model=self._model_name, contents=contents, config=config) # type: ignore |
| 327 | + return await func(model=self._model_name, contents=contents, config=config) |
328 | 328 | except json.JSONDecodeError as error:
|
329 | 329 | json_decode_error = error
|
330 | 330 | delay = base_delay * (2**attempt)
|
|
0 commit comments