Merge remote-tracking branch 'origin/master' into issue816_threadeddownload

Author: soxofaan

.github/workflows/unittests.yml

@@ -27,6 +27,7 @@ jobs:
           - "3.11"
           - "3.12"
           - "3.13"
+          - "3.14"
         # Additional special cases (see https://docs.github.com/en/actions/using-workflows/workflow-syntax-for-github-actions#example-adding-configurations)
         include:
           - os: "windows-latest"

CHANGELOG.md

@@ -9,12 +9,17 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+- Official support for Python 3.14 (include Python 3.14 in unit test matrix on GitHub Actions) ([#801](https://github.com/Open-EO/openeo-python-client/issues/801))
+- Add `on_response_headers_sync` option to  `openeo.connect`/`Connection` to set default `on_response_headers` handler for sync requests at connection level.
+
 ### Changed
 
 ### Removed
 
 ### Fixed
 
+- Guard STAC metadata parsing against invalid "item_assets" usage ([#853](https://github.com/Open-EO/openeo-python-client/issues/853))
+
 
 ## [0.47.0] - 2025-12-17
 

openeo/_version.py

@@ -1 +1 @@
-__version__ = "0.48.0a1"
+__version__ = "0.48.0a3"

openeo/metadata.py

@@ -603,6 +603,7 @@ def _parse_dimensions(cls, spec: dict, complain: Callable[[str], None] = _log.wa
             deep_get(spec, "summaries", "eo:bands", default=None)
             or deep_get(spec, "summaries", "bands", default=None)
             or deep_get(spec, "summaries", "raster:bands", default=None)
+            # TODO: drop this 0.4-style "properties/eo:bands"
             or deep_get(spec, "properties", "eo:bands", default=None)
         )
         if summaries_bands:
@@ -878,7 +879,12 @@ def bands_from_stac_collection(
         # Check item assets if available
         elif _PYSTAC_1_12_ITEM_ASSETS and collection.item_assets:
             return self._bands_from_item_assets(collection.item_assets)
-        elif _PYSTAC_1_9_EXTENSION_INTERFACE and collection.ext.has("item_assets") and collection.ext.item_assets:
+        elif (
+            _PYSTAC_1_9_EXTENSION_INTERFACE
+            and collection.ext.has("item_assets")
+            and collection.extra_fields.get("item-assets")
+            and collection.ext.item_assets
+        ):
             return self._bands_from_item_assets(collection.ext.item_assets)
         elif collection.extra_fields.get("item_assets"):
             # Workaround for lack of support for STAC 1.1 core item_assets with pystac < 1.12

openeo/rest/connection.py

@@ -107,6 +107,9 @@
 DEFAULT_TIMEOUT_SYNCHRONOUS_EXECUTE = 30 * 60
 
 
+ResponseHeadersHandler = Callable[[Mapping], None]
+
+
 class Connection(RestApiConnection):
     """
     Connection to an openEO backend.
@@ -134,8 +137,14 @@ class Connection(RestApiConnection):
         - ``None`` (default) to use default openEO-oriented retry settings
         - ``False`` to disable retrying requests
 
+    :param on_response_headers_sync: (optional) callback to handle (e.g. :py:func:`print`)
+        the response headers of synchronous processing requests.
+
     .. versionchanged:: 0.41.0
         Added ``retry`` argument.
+
+    .. versionchanged:: 0.48
+            Added argument ``on_response_headers_sync``.
     """
 
     _MINIMUM_API_VERSION = ComparableVersion("1.0.0")
@@ -153,6 +162,7 @@ def __init__(
         oidc_auth_renewer: Optional[OidcAuthenticator] = None,
         auth: Optional[AuthBase] = None,
         retry: Union[urllib3.util.Retry, dict, bool, None] = None,
+        on_response_headers_sync: Optional[ResponseHeadersHandler] = None,
     ):
         if "://" not in url:
             url = "https://" + url
@@ -172,6 +182,7 @@ def __init__(
         self._refresh_token_store = refresh_token_store
         self._oidc_auth_renewer = oidc_auth_renewer
         self._auto_validate = auto_validate
+        self._on_response_headers_sync = on_response_headers_sync
 
     @classmethod
     def version_discovery(
@@ -216,6 +227,37 @@ def _get_refresh_token_store(self) -> RefreshTokenStore:
             self._refresh_token_store = RefreshTokenStore()
         return self._refresh_token_store
 
+    def list_auth_providers(self) -> List[dict]:
+        providers = []
+        cap = self.capabilities()
+
+        # Add OIDC providers
+        oidc_path = "/credentials/oidc"
+        if cap.supports_endpoint(oidc_path, method="GET"):
+            try:
+                data = self.get(oidc_path, expected_status=200).json()
+                if isinstance(data, dict):
+                    for provider in data.get("providers", []):
+                        provider["type"] = "oidc"
+                        providers.append(provider)
+            except OpenEoApiError as e:
+                _log.warning(f"Unable to load the OpenID Connect provider list: {e.message}")
+
+        # Add Basic provider
+        basic_path = "/credentials/basic"
+        if cap.supports_endpoint(basic_path, method="GET"):
+            providers.append(
+                {
+                    "id": basic_path,
+                    "issuer": self.build_url(basic_path),
+                    "type": "basic",
+                    "title": "Internal",
+                    "description": "The HTTP Basic authentication method is mostly used for development and testing purposes.",
+                }
+            )
+
+        return providers
+
     def authenticate_basic(self, username: Optional[str] = None, password: Optional[str] = None) -> Connection:
         """
         Authenticate a user to the backend using basic username and password.
@@ -1681,7 +1723,7 @@ def download(
         chunk_size: int = DEFAULT_DOWNLOAD_CHUNK_SIZE,
         additional: Optional[dict] = None,
         job_options: Optional[dict] = None,
-        on_response_headers: Optional[Callable[[Mapping], None]] = None,
+        on_response_headers: Optional[ResponseHeadersHandler] = None,
     ) -> Union[None, bytes]:
         """
         Send the underlying process graph to the backend
@@ -1700,7 +1742,7 @@ def download(
         :param additional: (optional) additional (top-level) properties to set in the request body
         :param job_options: (optional) dictionary of job options to pass to the backend
             (under top-level property "job_options")
-        :param on_response_headers: (optional) callback to handle/show the response headers
+        :param on_response_headers: (optional) callback to handle (e.g. :py:func:`print`) the response headers.
 
         :return: if ``outputfile`` was not specified:
             a :py:class:`bytes` object containing the raw data.
@@ -1723,7 +1765,7 @@ def download(
             stream=True,
             timeout=timeout or DEFAULT_TIMEOUT_SYNCHRONOUS_EXECUTE,
         )
-        if on_response_headers:
+        if on_response_headers := (on_response_headers or self._on_response_headers_sync):
             on_response_headers(response.headers)
 
         if outputfile is not None:
@@ -1745,6 +1787,7 @@ def execute(
         auto_decode: bool = True,
         additional: Optional[dict] = None,
         job_options: Optional[dict] = None,
+        on_response_headers: Optional[ResponseHeadersHandler] = None,
     ) -> Union[dict, requests.Response]:
         """
         Execute a process graph synchronously and return the result. If the result is a JSON object, it will be parsed.
@@ -1757,11 +1800,15 @@ def execute(
         :param additional: additional (top-level) properties to set in the request body
         :param job_options: dictionary of job options to pass to the backend
             (under top-level property "job_options")
+        :param on_response_headers: (optional) callback to handle (e.g. :py:func:`print`) the response headers.
 
         :return: parsed JSON response as a dict if auto_decode is True, otherwise response object
 
         .. versionadded:: 0.36.0
             Added arguments ``additional`` and ``job_options``.
+
+        .. versionchanged:: 0.48
+            Added argument ``on_response_headers``.
         """
         pg_with_metadata = self._build_request_with_process_graph(
             process_graph=process_graph, additional=additional, job_options=job_options
@@ -1773,6 +1820,9 @@ def execute(
             expected_status=200,
             timeout=timeout or DEFAULT_TIMEOUT_SYNCHRONOUS_EXECUTE,
         )
+        if on_response_headers := (on_response_headers or self._on_response_headers_sync):
+            on_response_headers(response.headers)
+
         if auto_decode:
             try:
                 return response.json()
@@ -1962,6 +2012,7 @@ def connect(
     default_timeout: Optional[int] = None,
     auto_validate: bool = True,
     retry: Union[urllib3.util.Retry, dict, bool, None] = None,
+    on_response_headers_sync: Optional[ResponseHeadersHandler] = None,
 ) -> Connection:
     """
     This method is the entry point to OpenEO.
@@ -1989,11 +2040,17 @@ def connect(
         - ``None`` (default) to use default openEO-oriented retry settings
         - ``False`` to disable retrying requests
 
+    :param on_response_headers_sync: (optional) callback to handle (e.g. :py:func:`print`)
+        the response headers of synchronous processing requests.
+
     .. versionchanged:: 0.24.0
         Added ``auto_validate`` argument
 
     .. versionchanged:: 0.41.0
         Added ``retry`` argument.
+
+    .. versionchanged:: 0.48
+        Added argument ``on_response_headers_sync``.
     """
 
     def _config_log(message):
@@ -2024,6 +2081,7 @@ def _config_log(message):
         default_timeout=default_timeout,
         auto_validate=auto_validate,
         retry=retry,
+        on_response_headers_sync=on_response_headers_sync,
     )
 
     auth_type = auth_type.lower() if isinstance(auth_type, str) else auth_type

openeo/rest/datacube.py

@@ -300,7 +300,7 @@ def _build_load_properties_argument(
                 unsupported_properties = set(properties.keys()).difference(supported_properties)
                 if unsupported_properties:
                     warnings.warn(
-                        f"Property filtering with unsupported properties according to collection/STAC metadata: {unsupported_properties} (supported: {supported_properties}).",
+                        f"Property filtering with properties not listed in collection/STAC metadata: {list(unsupported_properties)} (supported: {list(supported_properties)}).",
                         stacklevel=3,
                     )
             properties = {
@@ -2456,7 +2456,7 @@ def download(
         :param additional: (optional) additional (top-level) properties to set in the request body
         :param job_options: (optional) dictionary of job options to pass to the backend
             (under top-level property "job_options")
-        :param on_response_headers: (optional) callback to handle/show the response headers
+        :param on_response_headers: (optional) callback to handle (e.g. :py:func:`print`) the response headers.
 
         :return: if ``outputfile`` was not specified:
             a :py:class:`bytes` object containing the raw data.
@@ -3072,6 +3072,34 @@ def unflatten_dimension(self, dimension: str, target_dimensions: List[str], labe
             ),
         )
 
+    @openeo_process
+    def aspect(self) -> DataCube:
+        """
+        Converts every band in the datacube to a band with suffix "_aspect" containing the aspect.
+
+        :return: A data cube with the same dimensions but containing the computed aspect values.
+        """
+        return self.process(
+            process_id="aspect",
+            arguments=dict_no_none(
+                data=THIS
+            ),
+        )
+
+    @openeo_process
+    def slope(self) -> DataCube:
+        """
+        Converts every band in the datacube to a band with suffix "_slope" containing the slope.
+
+        :return: A data cube with the same dimensions but containing the computed slope values.
+        """
+        return self.process(
+            process_id="slope",
+            arguments=dict_no_none(
+                data=THIS
+            ),
+        )
+
     @openeo_process
     def convert_data_type(
             self,

openeo/rest/stac_resource.py

@@ -102,7 +102,7 @@ def download(
         :param additional: (optional) additional (top-level) properties to set in the request body
         :param job_options: (optional) dictionary of job options to pass to the backend
             (under top-level property "job_options")
-        :param on_response_headers: (optional) callback to handle/show the response headers
+        :param on_response_headers: (optional) callback to handle (e.g. :py:func:`print`) the response headers.
 
         :return: if ``outputfile`` was not specified:
             a :py:class:`bytes` object containing the raw data.

openeo/rest/vectorcube.py

@@ -268,7 +268,7 @@ def download(
         :param additional: (optional) additional (top-level) properties to set in the request body
         :param job_options: (optional) dictionary of job options to pass to the backend
             (under top-level property "job_options")
-        :param on_response_headers: (optional) callback to handle/show the response headers
+        :param on_response_headers: (optional) callback to handle (e.g. :py:func:`print`) the response headers.
 
         :return: if ``outputfile`` was not specified:
             a :py:class:`bytes` object containing the raw data.
@@ -292,7 +292,12 @@ def download(
         else:
             res = self
         return self._connection.download(
-            res.flat_graph(), outputfile=outputfile, validate=validate, additional=additional, job_options=job_options
+            res.flat_graph(),
+            outputfile=outputfile,
+            validate=validate,
+            additional=additional,
+            job_options=job_options,
+            on_response_headers=on_response_headers,
         )
 
     def execute_batch(

setup.py

@@ -80,7 +80,7 @@
         "shapely>=1.6.4",
         "numpy>=1.17.0",
         "xarray>=0.12.3,<2025.01.2",  # TODO #721 xarray non-nanosecond support
-        "pandas>0.20.0",
+        "pandas>0.20.0,<3.0.0",  # TODO pandas 3 compatibility https://github.com/Open-EO/openeo-python-client/issues/856
         # TODO #578: pystac 1.5.0 is highest version available for lowest Python version we still support (3.7).
         "pystac>=1.5.0",
         "deprecated>=1.2.12",
@@ -108,6 +108,7 @@
         "Programming Language :: Python :: 3.11",
         "Programming Language :: Python :: 3.12",
         "Programming Language :: Python :: 3.13",
+        "Programming Language :: Python :: 3.14",
         "License :: OSI Approved :: Apache Software License",
         "Development Status :: 5 - Production/Stable",
         "Operating System :: OS Independent",

tests/rest/datacube/test_datacube100.py

@@ -2129,7 +2129,7 @@ def test_load_collection_max_cloud_cover_summaries_warning(
     if expect_warning:
         assert len(recwarn.list) == 1
         assert re.search(
-            "Property filtering.*unsupported.*collection.*metadata.*eo:cloud_cover",
+            "Property filtering.*properties not listed.*collection.*metadata.*eo:cloud_cover",
             str(recwarn.pop(UserWarning).message),
         )
     else: