feat(gooddata-sdk): [AUTO] Rename /ailake/object-storages path to /ailake/objectStorages

Author: yenkins-admin

packages/gooddata-sdk/pyproject.toml

@@ -76,7 +76,7 @@ test = [
 ]
 
 [tool.ty.analysis]
-allowed-unresolved-imports = ["gooddata_api_client.**"]
+allowed-unresolved-imports = ["gooddata_api_client.**", "pyarrow"]
 
 [tool.hatch.build.targets.wheel]
 packages = ["src/gooddata_sdk"]

packages/gooddata-sdk/src/gooddata_sdk/__init__.py

@@ -11,6 +11,7 @@
     CatalogAILakeOperation,
     CatalogAILakeOperationError,
     CatalogAILakeService,
+    CatalogObjectStorageInfo,
 )
 from gooddata_sdk.catalog.appearance.entity_model.color_palette import (
     CatalogColorPalette,

packages/gooddata-sdk/src/gooddata_sdk/catalog/ai_lake/service.py

@@ -29,6 +29,8 @@
 from gooddata_sdk.catalog.base import Base
 from gooddata_sdk.client import GoodDataApiClient
 
+_OBJECT_STORAGES_PATH = "api/v1/ailake/objectStorages"
+
 # AI Lake operation status values (lower-case on the wire — these are the
 # discriminator values of the `Operation` oneOf on the OpenAPI side).
 OperationStatus = Literal["pending", "succeeded", "failed"]
@@ -58,6 +60,25 @@ def is_failed(self) -> bool:
         return self.status == "failed"
 
 
+@define(kw_only=True)
+class CatalogObjectStorageInfo(Base):
+    """Information about a registered AI Lake object storage."""
+
+    name: str
+    storage_config: dict[str, str]
+    storage_id: str
+    storage_type: str
+
+    @classmethod
+    def from_api(cls, entity: dict[str, Any]) -> CatalogObjectStorageInfo:
+        return cls(
+            name=entity["name"],
+            storage_config=entity.get("storageConfig") or {},
+            storage_id=entity["storageId"],
+            storage_type=entity["storageType"],
+        )
+
+
 class CatalogAILakeOperationError(RuntimeError):
     """Raised when an AI Lake long-running operation finishes in `failed` state."""
 
@@ -76,6 +97,22 @@ def __init__(self, api_client: GoodDataApiClient) -> None:
         self._client = api_client
         self._ai_lake_api: AILakeApi = AILakeApi(api_client._api_client)
 
+    def list_object_storages(self) -> list[CatalogObjectStorageInfo]:
+        """List all object storages registered for the organization.
+
+        Uses the new `/api/v1/ailake/objectStorages` path (renamed from
+        the legacy `/api/v1/ailake/object-storages`).  The generated
+        api-client still references the old path, so this method bypasses
+        it and calls the endpoint directly.
+
+        Returns:
+            List of `CatalogObjectStorageInfo` objects, ordered by name.
+        """
+        response = self._client._do_get_request(_OBJECT_STORAGES_PATH)
+        response.raise_for_status()
+        data: dict[str, Any] = response.json()
+        return [CatalogObjectStorageInfo.from_api(s) for s in data.get("storages", [])]
+
     def analyze_statistics(
         self,
         instance_id: str,

packages/gooddata-sdk/src/gooddata_sdk/client.py

@@ -91,6 +91,30 @@ def __init__(
         self._ai_lake_api = apis.AILakeApi(self._api_client)
         self._executions_cancellable = executions_cancellable
 
+    def _do_get_request(
+        self,
+        endpoint: str,
+    ) -> requests.Response:
+        """Perform a GET request to a specified endpoint.
+
+        Args:
+            endpoint (str): The endpoint URL to which the request is made.
+
+        Returns:
+            requests.Response: The response from the HTTP request.
+        """
+        if not self._hostname.endswith("/"):
+            endpoint = f"/{endpoint}"
+
+        response = requests.get(
+            url=f"{self._hostname}{endpoint}",
+            headers={
+                "Authorization": f"Bearer {self._token}",
+            },
+        )
+
+        return response
+
     def _do_post_request(
         self,
         data: bytes,

packages/gooddata-sdk/src/gooddata_sdk/compute/model/execution.py

@@ -19,8 +19,8 @@
     import pyarrow as _pyarrow
     from pyarrow import ipc as _ipc
 except ImportError:
-    _pyarrow = None  # type: ignore
-    _ipc = None  # type: ignore
+    _pyarrow = None
+    _ipc = None
 
 from gooddata_sdk.client import GoodDataApiClient
 from gooddata_sdk.compute.model.attribute import Attribute

packages/gooddata-sdk/src/gooddata_sdk/compute/model/filter.py

@@ -326,7 +326,7 @@ def __init__(
         self._from_shift = from_shift
         self._to_shift = to_shift
         self._bounded_filter = bounded_filter
-        self._empty_value_handling = empty_value_handling
+        self._empty_value_handling: EmptyValueHandling | None = empty_value_handling
 
     @property
     def dataset(self) -> ObjId:
@@ -435,7 +435,7 @@ def __init__(
 
         self._dataset = dataset
         self._granularity = granularity
-        self._empty_value_handling = empty_value_handling
+        self._empty_value_handling: EmptyValueHandling | None = empty_value_handling
 
     @property
     def dataset(self) -> ObjId:
@@ -490,7 +490,7 @@ def __init__(
         self._dataset = dataset
         self._from_date = from_date
         self._to_date = to_date
-        self._empty_value_handling = empty_value_handling
+        self._empty_value_handling: EmptyValueHandling | None = empty_value_handling
 
     @property
     def dataset(self) -> ObjId:

packages/gooddata-sdk/tests/catalog/test_ai_lake_service.py

@@ -0,0 +1,26 @@
+# (C) 2026 GoodData Corporation
+"""Integration tests for `CatalogAILakeService`."""
+
+from __future__ import annotations
+
+from pathlib import Path
+
+from gooddata_sdk import CatalogObjectStorageInfo, GoodDataSdk
+from tests_support.vcrpy_utils import get_vcr
+
+gd_vcr = get_vcr()
+
+_current_dir = Path(__file__).parent.absolute()
+_fixtures_dir = _current_dir / "fixtures" / "ai_lake"
+
+
+@gd_vcr.use_cassette(str(_fixtures_dir / "test_list_object_storages.yaml"))
+def test_list_object_storages(test_config):
+    sdk = GoodDataSdk.create(host_=test_config["host"], token_=test_config["token"])
+    storages = sdk.catalog_ai_lake.list_object_storages()
+    assert isinstance(storages, list)
+    for s in storages:
+        assert isinstance(s, CatalogObjectStorageInfo)
+        assert s.name
+        assert s.storage_id
+        assert s.storage_type