diff --git a/src/finch/_base_client.py b/src/finch/_base_client.py index 9a023ba9..a168301f 100644 --- a/src/finch/_base_client.py +++ b/src/finch/_base_client.py @@ -863,7 +863,7 @@ def _request( self._prepare_request(request) try: - response = self._client.send(request, auth=self.custom_auth, stream=stream or options.stream or False) + response = self._client.send(request, auth=self.custom_auth, stream=stream) log.debug( 'HTTP Request: %s %s "%i %s"', request.method, request.url, response.status_code, response.reason_phrase ) @@ -1304,7 +1304,7 @@ async def _request( await self._prepare_request(request) try: - response = await self._client.send(request, auth=self.custom_auth, stream=stream or options.stream or False) + response = await self._client.send(request, auth=self.custom_auth, stream=stream) log.debug( 'HTTP Request: %s %s "%i %s"', request.method, request.url, response.status_code, response.reason_phrase ) @@ -1541,7 +1541,6 @@ def make_request_options( idempotency_key: str | None = None, timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, post_parser: PostParser | NotGiven = NOT_GIVEN, - stream: bool | None = None, ) -> RequestOptions: """Create a dict of type RequestOptions without keys of NotGiven values.""" options: RequestOptions = {} @@ -1563,9 +1562,6 @@ def make_request_options( if idempotency_key is not None: options["idempotency_key"] = idempotency_key - if stream is not None: - options["stream"] = stream - if is_given(post_parser): # internal options["post_parser"] = post_parser # type: ignore diff --git a/src/finch/_models.py b/src/finch/_models.py index a0e59614..5b8c9601 100644 --- a/src/finch/_models.py +++ b/src/finch/_models.py @@ -403,7 +403,6 @@ class FinalRequestOptionsInput(TypedDict, total=False): params: Query headers: Headers max_retries: int - stream: bool | None timeout: float | Timeout | None files: HttpxRequestFiles | None idempotency_key: str @@ -421,7 +420,6 @@ class FinalRequestOptions(pydantic.BaseModel): timeout: Union[float, Timeout, None, NotGiven] = NotGiven() files: Union[HttpxRequestFiles, None] = None idempotency_key: Union[str, None] = None - stream: Union[bool, None] = None post_parser: Union[Callable[[Any], Any], NotGiven] = NotGiven() # It should be noted that we cannot use `json` here as that would override diff --git a/src/finch/_types.py b/src/finch/_types.py index 1e04f89d..e12f064d 100644 --- a/src/finch/_types.py +++ b/src/finch/_types.py @@ -257,7 +257,6 @@ async def aclose(self) -> None: class RequestOptions(TypedDict, total=False): headers: Headers max_retries: int - stream: bool timeout: float | Timeout | None params: Query extra_json: AnyMapping