Merge branch 'main' into fix/7119-session-events-leak

Author: AnupamKumar-1

.release-please-manifest.json

@@ -1,3 +1,3 @@
 {
-    ".": "2.0.1"
+    ".": "2.1.0"
 }

CHANGELOG.md

@@ -1,5 +1,26 @@
 # Changelog
 
+## [2.1.0](https://github.com/googleapis/python-aiplatform/compare/v2.0.1...v2.1.0) (2026-09-01)
+
+
+### Features
+
+* Add execute_bash to the Agent Engine sandbox SDK. ([505bd42](https://github.com/googleapis/python-aiplatform/commit/505bd42f65a8730793c7592ffa61d3f5b80f04cf))
+* Allow setting `ingress_control_config` when creating a `SandboxEnvironmentTemplate` via the SDK (Python, Java, JS). ([2dccde8](https://github.com/googleapis/python-aiplatform/commit/2dccde8797ea3bb1137170f2f377e3f978209b1c))
+* Expose SandboxEnvironmentTemplateState as a standalone enum class in the Python, Java, and JS SDKs. ([a31d2ba](https://github.com/googleapis/python-aiplatform/commit/a31d2ba1887966e6f65624526095cdc941c4748d))
+* Expose STATE_PAUSED, STATE_PAUSING, and STATE_RESUMING values in the SandboxState enum for SandboxEnvironment across Python, Java, and JS SDKs. ([ec342d9](https://github.com/googleapis/python-aiplatform/commit/ec342d94ab1c9fd43f4cee5679b8e7d349a92396))
+
+
+### Bug Fixes
+
+* Guard the post-LRO refresh in sandboxes.pause() and sandboxes.resume() on the presence of a resource name in the LRO response. ([2c60077](https://github.com/googleapis/python-aiplatform/commit/2c60077ae9ca124e87dc53be1c759a81ab074923))
+* Preserve rrf_ranking_alpha=0.0 in MatchingEngineIndexEndpoint hybrid queries ([7e1c95a](https://github.com/googleapis/python-aiplatform/commit/7e1c95a7aec5ab2d122e454a467ab489cfb7baad))
+
+
+### Documentation
+
+* Update CHANGELOG.md to mark version 2.0.0 as yanked ([75f9361](https://github.com/googleapis/python-aiplatform/commit/75f9361e0038cbe80585b94cd052da63aafe4672))
+
 ## [2.0.1](https://github.com/googleapis/python-aiplatform/compare/v2.0.0...v2.0.1) (2026-08-28)
 
 

agentplatform/_genai/sandboxes.py

@@ -1168,6 +1168,85 @@ def execute_code(
 
         return response
 
+    def execute_bash(
+        self,
+        *,
+        name: str,
+        command: str,
+        cwd: Optional[str] = None,
+        timeout: Optional[int] = None,
+        port: str = "8080",
+        config: Optional[types.ExecuteCodeRuntimeSandboxConfigOrDict] = None,
+    ) -> dict[str, Any]:
+        """Runs a bash command in a shell sandbox.
+
+        The sandbox must have been created with a shell environment, either by
+        passing `spec={"shell_environment": {}}` to `create()` or by referencing a
+        template whose `default_container_category` is
+        `DEFAULT_CONTAINER_CATEGORY_SHELL_SANDBOX`.
+
+        Unlike `send_command`, this authenticates with the caller's own credentials,
+        so it needs no service account and no signed JWT.
+
+        Args:
+            name (str):
+                Required. The name of the agent engine sandbox to run the command
+                in, of the form
+                projects/*/locations/*/reasoningEngines/*/sandboxEnvironments/*.
+            command (str):
+                Required. The bash command to run.
+            cwd (str):
+                Optional. The working directory to run the command in. Defaults to
+                the sandbox's workspace directory.
+            timeout (int):
+                Optional. Seconds to allow the command to run before the sandbox
+                kills it. Defaults to the sandbox's own limit.
+            port (str):
+                Optional. The port the shell server listens on. Defaults to "8080".
+            config (ExecuteCodeRuntimeSandboxConfigOrDict):
+                Optional. The configuration for the request.
+
+        Returns:
+            dict[str, Any]: The result of the command, with keys `stdout`,
+            `stderr`, `returncode` and `duration_ms`. A command that exits
+            non-zero is reported here rather than raised.
+
+        Raises:
+            ValueError: If the sandbox returns no output.
+        """
+        request: dict[str, Any] = {"command": command}
+        if cwd is not None:
+            request["cwd"] = cwd
+        if timeout is not None:
+            request["timeout"] = timeout
+
+        # The sandbox proxy addresses the container by URI and port, and forwards
+        # the JSON chunk as the POST body.
+        response = self._execute_code(
+            name=name,
+            inputs=[
+                types.Chunk(
+                    mime_type="application/x.sandbox-request-uri",
+                    data=b"/exec",
+                ),
+                types.Chunk(
+                    mime_type="application/x.sandbox-request-port",
+                    data=port.encode("utf-8"),
+                ),
+                types.Chunk(
+                    mime_type="application/json",
+                    data=json.dumps(request).encode("utf-8"),
+                ),
+            ],
+            config=config,
+        )
+
+        for output in response.outputs or []:
+            if output.data:
+                return json.loads(output.data.decode("utf-8"))
+
+        raise ValueError(f"The sandbox {name} returned no output for the command.")
+
     def get(
         self,
         *,

agentplatform/version.py

@@ -14,4 +14,4 @@
 #
 """Version file for agentplatform."""
 
-__version__ = "2.0.1"
+__version__ = "2.1.0"

google/cloud/aiplatform/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.0.1"  # {x-release-please-version}
+__version__ = "2.1.0"  # {x-release-please-version}

google/cloud/aiplatform/v1/schema/predict/instance/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.0.1"  # {x-release-please-version}
+__version__ = "2.1.0"  # {x-release-please-version}

google/cloud/aiplatform/v1/schema/predict/instance_v1/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.0.1"  # {x-release-please-version}
+__version__ = "2.1.0"  # {x-release-please-version}

google/cloud/aiplatform/v1/schema/predict/params/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.0.1"  # {x-release-please-version}
+__version__ = "2.1.0"  # {x-release-please-version}

google/cloud/aiplatform/v1/schema/predict/params_v1/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.0.1"  # {x-release-please-version}
+__version__ = "2.1.0"  # {x-release-please-version}

google/cloud/aiplatform/v1/schema/predict/prediction/gapic_version.py

@@ -13,4 +13,4 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 #
-__version__ = "2.0.1"  # {x-release-please-version}
+__version__ = "2.1.0"  # {x-release-please-version}