Merge branch 'googleapis:main' into main

Author: elibatelibat-blip

CHANGELOG.md

@@ -1,5 +1,60 @@
 # Changelog
 
+## [1.73.1](https://github.com/googleapis/python-genai/compare/v1.73.0...v1.73.1) (2026-04-14)
+
+
+### Bug Fixes
+
+* Refactor Webhook types in GenAI SDKs for easier useage ([3f36ca1](https://github.com/googleapis/python-genai/commit/3f36ca11b30904c8f82dd3e7e3b59eff3bde6a3b))
+* Rename `webhooks.retrieve` to `webhooks.get`. ([649f4b0](https://github.com/googleapis/python-genai/commit/649f4b06d7bd78a23dd77b06713c6ca5c65321f9))
+
+
+### Documentation
+
+* Update python docs for 1.73.0 ([acd3767](https://github.com/googleapis/python-genai/commit/acd3767bff513524172ddd7726b147d01c245f1c))
+
+## [1.73.0](https://github.com/googleapis/python-genai/compare/v1.72.0...v1.73.0) (2026-04-13)
+
+
+### Features
+
+* Add DeepResearchAgentConfig fields ([ec8ca87](https://github.com/googleapis/python-genai/commit/ec8ca87e6e0a80d363ebceadeacb623c0f479776))
+* Add webhook and webhookConfig for js and python sdk ([ccec350](https://github.com/googleapis/python-genai/commit/ccec35073534930130993443e4dea9bed6b07006))
+* Add webhook_config to batches.create() and models.generate_videos() ([772d2fc](https://github.com/googleapis/python-genai/commit/772d2fc0a716e5a23ab241b1efcb1dc5c73fde9e))
+* Wire the webhook into python and js client. ([841bf22](https://github.com/googleapis/python-genai/commit/841bf220d0bf1c539ab349998afb388118c6af05))
+
+
+### Bug Fixes
+
+* Refine Pyink blank line insertion logic and fix range-based formatting regressions. ([b91bda5](https://github.com/googleapis/python-genai/commit/b91bda5d587ee6217fcff8f4e1b8eee4aebb9203))
+
+## [1.72.0](https://github.com/googleapis/python-genai/compare/v1.71.0...v1.72.0) (2026-04-09)
+
+
+### Features
+
+* Add "eu" as a supported service location for Vertex AI platform. ([888a731](https://github.com/googleapis/python-genai/commit/888a73159db17a8f08f928ee1a85e80db1a85a1a))
+* Add Live Avatar new fields ([ad1777e](https://github.com/googleapis/python-genai/commit/ad1777e29e28677101c9a26bdff6fd32e103340b))
+* Add support for new audio MIME types: opus, alaw, and mulaw ([74eb373](https://github.com/googleapis/python-genai/commit/74eb373b2e97291e1d07cedce7cbf1fb82123a18))
+* Add the delete method for the Agent Engine Task Store Service ([d821082](https://github.com/googleapis/python-genai/commit/d821082a91effba4dc684b03b438e51527deed03))
+
+
+### Documentation
+
+* Update python docs for 1.71.0 ([e82f9fc](https://github.com/googleapis/python-genai/commit/e82f9fc9093825b3d5c4388c7faefe0c733f154b))
+
+## [1.71.0](https://github.com/googleapis/python-genai/compare/v1.70.0...v1.71.0) (2026-04-08)
+
+
+### Features
+
+* Introduce TYPE_L16 audio content and optional fields. ([07e932f](https://github.com/googleapis/python-genai/commit/07e932f9bc8dcb224ced2b35061ede9df25432cb))
+
+
+### Documentation
+
+* Remove deprecated product recontext model samples from docstrings ([aca7dcf](https://github.com/googleapis/python-genai/commit/aca7dcf32b15ef2d945a14fb498be0e9c096c0d8))
+
 ## [1.70.0](https://github.com/googleapis/python-genai/compare/v1.69.0...v1.70.0) (2026-03-31)
 
 

docs/genai.html

@@ -91,6 +91,8 @@
 INITIAL_RETRY_DELAY = 1  # second
 DELAY_MULTIPLIER = 2
 
+_MULTI_REGIONAL_LOCATIONS = {'us', 'eu'}
+
 
 class EphemeralTokenAPIKeyError(ValueError):
   """Error raised when the API key is invalid."""
@@ -702,7 +704,10 @@ def __init__(
           self.api_key or self.location == 'global'
       ) and not self.custom_base_url:
         self._http_options.base_url = f'https://aiplatform.googleapis.com/'
-      elif self.location == 'us' and not self.custom_base_url:
+      elif (
+          self.location in _MULTI_REGIONAL_LOCATIONS
+          and not self.custom_base_url
+      ):
         self._http_options.base_url = (
             f'https://aiplatform.{self.location}.rep.googleapis.com/'
         )
@@ -772,7 +777,7 @@ def __init__(
       self._async_httpx_client = AsyncHttpxClient(**async_client_args)
 
     # Initialize the aiohttp client session.
-    self._aiohttp_session: Optional[aiohttp.ClientSession] = None
+    self._aiohttp_session: Optional[Union['aiohttp.ClientSession', 'AsyncAuthorizedSession']] = None
     if self._use_aiohttp():
       try:
         import aiohttp  # pylint: disable=g-import-not-at-top
@@ -836,15 +841,15 @@ async def _get_aiohttp_session(
         from google.auth.aio.transport.sessions import AsyncAuthorizedSession
 
         async_creds = StaticCredentials(token=self._access_token())  # type: ignore[no-untyped-call]
-        self._aiohttp_session = AsyncAuthorizedSession(async_creds)  # type: ignore[no-untyped-call]
-        return self._aiohttp_session
+        self._aiohttp_session = AsyncAuthorizedSession(async_creds)  # type: ignore[no-untyped-call,assignment]
+        return self._aiohttp_session  # type: ignore[return-value]
       except ImportError:
         pass
 
     if not self._use_google_auth_async() and (
         self._aiohttp_session is None
-        or self._aiohttp_session.closed
-        or self._aiohttp_session._loop.is_closed()
+        or self._aiohttp_session.closed  # type: ignore[union-attr]
+        or self._aiohttp_session._loop.is_closed()  # type: ignore[union-attr]
     ):  # pylint: disable=protected-access
       # Initialize the aiohttp client session if it's not set up or closed.
       class AiohttpClientSession(aiohttp.ClientSession):  # type: ignore[misc]
@@ -883,7 +888,7 @@ def __del__(self, _warnings: Any = warnings) -> None:
           read_bufsize=READ_BUFFER_SIZE,
       )
 
-    return self._aiohttp_session
+    return self._aiohttp_session  # type: ignore[return-value]
 
   @staticmethod
   def _ensure_httpx_ssl_ctx(
@@ -1348,7 +1353,7 @@ async def _async_request_once(
 
     if stream:
       if self._use_aiohttp():
-        self._aiohttp_session = await self._get_aiohttp_session()
+        self._aiohttp_session = await self._get_aiohttp_session()  # type: ignore[assignment]
         url = http_request.url
         if self._use_google_auth_async():
           client_cert_source = mtls.default_client_cert_source()  # type: ignore[no-untyped-call]
@@ -1363,7 +1368,7 @@ async def _async_request_once(
             else:
               url = url.replace('googleapis.com', 'mtls.googleapis.com')
         try:
-          response = await self._aiohttp_session.request(
+          response = await self._aiohttp_session.request(  # type: ignore[union-attr]
               method=http_request.method,
               url=url,
               headers=http_request.headers,
@@ -1384,8 +1389,8 @@ async def _async_request_once(
               self._ensure_aiohttp_ssl_ctx(self._http_options)
           )
           # Instantiate a new session with the updated SSL context.
-          self._aiohttp_session = await self._get_aiohttp_session()
-          response = await self._aiohttp_session.request(
+          self._aiohttp_session = await self._get_aiohttp_session()  # type: ignore[assignment]
+          response = await self._aiohttp_session.request(  # type: ignore[union-attr]
               method=http_request.method,
               url=url,
               headers=http_request.headers,
@@ -1417,7 +1422,7 @@ async def _async_request_once(
         return HttpResponse(client_response.headers, client_response)
     else:
       if self._use_aiohttp():
-        self._aiohttp_session = await self._get_aiohttp_session()
+        self._aiohttp_session = await self._get_aiohttp_session()  # type: ignore[assignment]
         url = http_request.url
         if self._use_google_auth_async():
           client_cert_source = mtls.default_client_cert_source()  # type: ignore[no-untyped-call]
@@ -1432,7 +1437,7 @@ async def _async_request_once(
             else:
               url = url.replace('googleapis.com', 'mtls.googleapis.com')
         try:
-          response = await self._aiohttp_session.request(
+          response = await self._aiohttp_session.request(  # type: ignore[union-attr]
               method=http_request.method,
               url=url,
               headers=http_request.headers,
@@ -1461,8 +1466,8 @@ async def _async_request_once(
               self._ensure_aiohttp_ssl_ctx(self._http_options)
           )
           # Instantiate a new session with the updated SSL context.
-          self._aiohttp_session = await self._get_aiohttp_session()
-          response = await self._aiohttp_session.request(
+          self._aiohttp_session = await self._get_aiohttp_session()  # type: ignore[assignment]
+          response = await self._aiohttp_session.request(  # type: ignore[union-attr]
               method=http_request.method,
               url=url,
               headers=http_request.headers,
@@ -1857,7 +1862,7 @@ async def _async_upload_fd(
 
     # Upload the file in chunks
     if self._use_aiohttp():  # pylint: disable=g-import-not-at-top
-      self._aiohttp_session = await self._get_aiohttp_session()
+      self._aiohttp_session = await self._get_aiohttp_session()  # type: ignore[assignment]
       while True:
         if isinstance(file, io.IOBase):
           file_chunk = file.read(CHUNK_SIZE)
@@ -1899,7 +1904,7 @@ async def _async_upload_fd(
         retry_count = 0
         response = None
         while retry_count < MAX_RETRY_COUNT:
-          response = await self._aiohttp_session.request(
+          response = await self._aiohttp_session.request(  # type: ignore[union-attr]
               method='POST',
               url=upload_url,
               data=file_chunk,
@@ -2049,8 +2054,8 @@ async def async_download_file(
         data = http_request.data
 
     if self._use_aiohttp():
-      self._aiohttp_session = await self._get_aiohttp_session()
-      response = await self._aiohttp_session.request(
+      self._aiohttp_session = await self._get_aiohttp_session()  # type: ignore[assignment]
+      response = await self._aiohttp_session.request(  # type: ignore[union-attr]
           method=http_request.method,
           url=http_request.url,
           headers=http_request.headers,

docs/genindex.html

@@ -550,6 +550,10 @@ def _build_request(
                 files = cast(HttpxRequestFiles, ForceMultipartDict())
 
         prepared_url = self._prepare_url(options.url)
+        # preserve hard-coded query params from the url
+        if params and prepared_url.query:
+            params = {**dict(prepared_url.params.items()), **params}
+            prepared_url = prepared_url.copy_with(raw_path=prepared_url.raw_path.split(b"?", 1)[0])
         if "_" in prepared_url.host:
             # work around https://github.com/encode/httpx/discussions/2880
             kwargs["extensions"] = {"sni_hostname": prepared_url.host.replace("_", "-")}

docs/index.html

@@ -49,7 +49,8 @@
 from ._client_adapter import GeminiNextGenAPIClientAdapter, AsyncGeminiNextGenAPIClientAdapter
 
 if TYPE_CHECKING:
-    from .resources import interactions
+    from .resources import webhooks, interactions
+    from .resources.webhooks import WebhooksResource, AsyncWebhooksResource
     from .resources.interactions import InteractionsResource, AsyncInteractionsResource
 
 __all__ = [
@@ -133,6 +134,12 @@ def interactions(self) -> InteractionsResource:
 
         return InteractionsResource(self)
 
+    @cached_property
+    def webhooks(self) -> WebhooksResource:
+        from .resources.webhooks import WebhooksResource
+
+        return WebhooksResource(self)
+
     @cached_property
     def with_raw_response(self) -> GeminiNextGenAPIClientWithRawResponse:
         return GeminiNextGenAPIClientWithRawResponse(self)
@@ -354,6 +361,12 @@ def interactions(self) -> AsyncInteractionsResource:
 
         return AsyncInteractionsResource(self)
 
+    @cached_property
+    def webhooks(self) -> AsyncWebhooksResource:
+        from .resources.webhooks import AsyncWebhooksResource
+
+        return AsyncWebhooksResource(self)
+
     @cached_property
     def with_raw_response(self) -> AsyncGeminiNextGenAPIClientWithRawResponse:
         return AsyncGeminiNextGenAPIClientWithRawResponse(self)
@@ -518,6 +531,12 @@ def interactions(self) -> interactions.InteractionsResourceWithRawResponse:
 
         return InteractionsResourceWithRawResponse(self._client.interactions)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithRawResponse:
+        from .resources.webhooks import WebhooksResourceWithRawResponse
+
+        return WebhooksResourceWithRawResponse(self._client.webhooks)
+
 
 class AsyncGeminiNextGenAPIClientWithRawResponse:
     _client: AsyncGeminiNextGenAPIClient
@@ -531,6 +550,12 @@ def interactions(self) -> interactions.AsyncInteractionsResourceWithRawResponse:
 
         return AsyncInteractionsResourceWithRawResponse(self._client.interactions)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithRawResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithRawResponse
+
+        return AsyncWebhooksResourceWithRawResponse(self._client.webhooks)
+
 
 class GeminiNextGenAPIClientWithStreamedResponse:
     _client: GeminiNextGenAPIClient
@@ -544,6 +569,12 @@ def interactions(self) -> interactions.InteractionsResourceWithStreamingResponse
 
         return InteractionsResourceWithStreamingResponse(self._client.interactions)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import WebhooksResourceWithStreamingResponse
+
+        return WebhooksResourceWithStreamingResponse(self._client.webhooks)
+
 
 class AsyncGeminiNextGenAPIClientWithStreamedResponse:
     _client: AsyncGeminiNextGenAPIClient
@@ -557,6 +588,12 @@ def interactions(self) -> interactions.AsyncInteractionsResourceWithStreamingRes
 
         return AsyncInteractionsResourceWithStreamingResponse(self._client.interactions)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithStreamingResponse
+
+        return AsyncWebhooksResourceWithStreamingResponse(self._client.webhooks)
+
 
 Client = GeminiNextGenAPIClient