Issue #747 please the linter (ran pre-commit on all)

Author: dsamaey

docs/conf.py

@@ -13,13 +13,14 @@
 # All configuration values have a default; values that are commented out
 # serve to show the default.
 
+import datetime
+
 # If extensions (or modules to document with autodoc) are in another directory,
 # add these directories to sys.path here. If the directory is relative to the
 # documentation root, use os.path.abspath to make it absolute, like shown here.
 #
 import os
 import sys
-import datetime
 
 sys.path.insert(0, os.path.abspath('.'))
 sys.path.insert(0, os.path.abspath('../'))
@@ -44,6 +45,7 @@
 ]
 
 import sphinx_autodoc_typehints
+
 # Add any paths that contain templates here, relative to this directory.
 templates_path = ['_templates']
 

docs/cookbook/sampling.md

@@ -6,10 +6,10 @@ but rather want to extract a result at specific locations.
 Examples include extracting training data for model calibration, or computing the result for
 areas where validation data is available.
 
-An important constraint is that most implementations assume that sampling is an operation 
-on relatively small areas, of for instance up to 512x512 pixels (but often much smaller). 
+An important constraint is that most implementations assume that sampling is an operation
+on relatively small areas, of for instance up to 512x512 pixels (but often much smaller).
 When extracting polygons with larger areas, it is recommended to look into running a separate job per 'sample'.
-Some more important performance notices are mentioned later in the chapter, please read them carefully 
+Some more important performance notices are mentioned later in the chapter, please read them carefully
 to get best results.
 
 Sampling can be done for points or polygons:
@@ -23,9 +23,9 @@ public url, and to load it in openEO using {py:meth}`openeo.rest.connection.Conn
 
 ## Sampling at point locations
 
-To sample point locations, the `openeo.rest.datacube.DataCube.aggregate_spatial` method can be used. The reducer can be a 
+To sample point locations, the `openeo.rest.datacube.DataCube.aggregate_spatial` method can be used. The reducer can be a
 commonly supported reducer like `min`, `max` or `mean` and will receive only one value as input in most cases. Note that
-in edge cases, a point can intersect with up to 4 pixels. If this is not desirable, it might be worth trying to align 
+in edge cases, a point can intersect with up to 4 pixels. If this is not desirable, it might be worth trying to align
 points with pixel centers, which does require more advanced knowledge of the pixel grid of your data cube.
 
 More information on `aggregate_spatial` is available [here](_aggregate-spatial-evi).

examples/archive/udf/udf_modify_spatial.py

@@ -1,8 +1,10 @@
+import numpy as np
 import xarray
+
+from openeo.metadata import CollectionMetadata
 from openeo.udf import XarrayDataCube
 from openeo.udf.debug import inspect
-from openeo.metadata import CollectionMetadata
-import numpy as np
+
 
 def apply_metadata(input_metadata:CollectionMetadata, context:dict) -> CollectionMetadata:
 
@@ -41,4 +43,4 @@ def apply_datacube(cube: XarrayDataCube, context: dict) -> XarrayDataCube:
     predicted_cube = xarray.DataArray(predicted_array, dims=['bands', 'x', 'y'], coords=dict(x=coord_x, y=coord_y))
 
 
-    return XarrayDataCube(predicted_cube)
+    return XarrayDataCube(predicted_cube)

openeo/extra/job_management/__init__.py

@@ -673,20 +673,20 @@ def _cancel_prolonged_job(self, job: BatchJob, row):
         try:
             # Ensure running start time is valid
             job_running_start_time = rfc3339.parse_datetime(row.get("running_start_time"), with_timezone=True)
-            
+
             # Parse the current time into a datetime object with timezone info
             current_time = rfc3339.parse_datetime(rfc3339.utcnow(), with_timezone=True)
 
             # Calculate the elapsed time between job start and now
             elapsed = current_time - job_running_start_time
 
             if elapsed > self._cancel_running_job_after:
-    
+
                 _log.info(
                     f"Cancelling long-running job {job.job_id} (after {elapsed}, running since {job_running_start_time})"
                 )
                 job.stop()
-                
+
         except Exception as e:
             _log.error(f"Unexpected error while handling job {job.job_id}: {e}")
 

openeo/extra/job_management/stac_job_db.py

@@ -53,7 +53,7 @@ def __init__(
 
     def exists(self) -> bool:
         return any(c.id == self.collection_id for c in self.client.get_collections())
-    
+
     def _normalize_df(self, df: pd.DataFrame) -> pd.DataFrame:
         """
         Normalize the given dataframe to be compatible with :py:class:`MultiBackendJobManager`

openeo/processes.py

@@ -2867,7 +2867,8 @@ def aggregate_spatial(data, geometries, reducer, target_dimension=UNSET, context
         aggregated values (i.e. no-data). The spatial dimensions are replaced by a dimension of type 'geometries'
         and if `target_dimension` is not `null`, a new dimension is added.
     """
-    return _process('aggregate_spatial', 
+    return _process(
+        "aggregate_spatial",
         data=data,
         geometries=geometries,
         reducer=build_child_callback(reducer, parent_parameters=['data', 'context']),
@@ -2903,7 +2904,8 @@ def aggregate_spatial_window(data, reducer, size, boundary=UNSET, align=UNSET, c
         labels will be set to the coordinate at the center of the window. The other dimension properties (name,
         type and reference system) remain unchanged.
     """
-    return _process('aggregate_spatial_window', 
+    return _process(
+        "aggregate_spatial_window",
         data=data,
         reducer=build_child_callback(reducer, parent_parameters=['data', 'context']),
         size=size,
@@ -2942,7 +2944,8 @@ def aggregate_temporal(data, intervals, reducer, labels=UNSET, dimension=UNSET,
         system and resolution) remain unchanged, except for the resolution and dimension labels of the given
         temporal dimension.
     """
-    return _process('aggregate_temporal', 
+    return _process(
+        "aggregate_temporal",
         data=data,
         intervals=intervals,
         reducer=build_child_callback(reducer, parent_parameters=['data', 'context']),
@@ -2996,7 +2999,8 @@ def aggregate_temporal_period(data, period, reducer, dimension=UNSET, context=UN
         the source data cube has just one dimension label `2020-01-05`, the process returns a data cube with just a
         single dimension label (`2020-005`).
     """
-    return _process('aggregate_temporal_period', 
+    return _process(
+        "aggregate_temporal_period",
         data=data,
         period=period,
         reducer=build_child_callback(reducer, parent_parameters=['data', 'context']),
@@ -3137,7 +3141,8 @@ def apply_dimension(data, process, dimension, target_dimension=UNSET, context=UN
         incrementing integers starting from zero, - the resolution changes, and - the reference system is
         undefined.
     """
-    return _process('apply_dimension', 
+    return _process(
+        "apply_dimension",
         data=data,
         process=build_child_callback(process, parent_parameters=['data', 'context']),
         dimension=dimension,
@@ -3195,7 +3200,8 @@ def apply_neighborhood(data, process, size, overlap=UNSET, context=UNSET) -> Pro
     :return: A raster data cube with the newly computed values and the same dimensions. The dimension
         properties (name, type, labels, reference system and resolution) remain unchanged.
     """
-    return _process('apply_neighborhood', 
+    return _process(
+        "apply_neighborhood",
         data=data,
         process=build_child_callback(process, parent_parameters=['data', 'context']),
         size=size,
@@ -3224,7 +3230,8 @@ def apply_polygon(data, polygons, process, mask_value=UNSET, context=UNSET) -> P
     :return: A data cube with the newly computed values and the same dimensions. The dimension properties
         (name, type, labels, reference system and resolution) remain unchanged.
     """
-    return _process('apply_polygon', 
+    return _process(
+        "apply_polygon",
         data=data,
         polygons=polygons,
         process=build_child_callback(process, parent_parameters=['data', 'context']),
@@ -3318,7 +3325,8 @@ def ard_normalized_radar_backscatter(data, elevation_model=UNSET, contributing_a
         DEM-based local incidence angles in degrees.  The data returned is CARD4L compliant with corresponding
         metadata.
     """
-    return _process('ard_normalized_radar_backscatter', 
+    return _process(
+        "ard_normalized_radar_backscatter",
         data=data,
         elevation_model=elevation_model,
         contributing_area=contributing_area,
@@ -3373,7 +3381,8 @@ def ard_surface_reflectance(data, atmospheric_correction_method, cloud_detection
         (optional): Contains coefficients used for terrain illumination correction are provided for each pixel.
         The data returned is CARD4L compliant with corresponding metadata.
     """
-    return _process('ard_surface_reflectance', 
+    return _process(
+        "ard_surface_reflectance",
         data=data,
         atmospheric_correction_method=atmospheric_correction_method,
         cloud_detection_method=cloud_detection_method,
@@ -3413,7 +3422,8 @@ def array_apply(data, process, context=UNSET) -> ProcessBuilder:
     :return: An array with the newly computed values. The number of elements are the same as for the original
         array.
     """
-    return _process('array_apply', 
+    return _process(
+        "array_apply",
         data=data,
         process=build_child_callback(process, parent_parameters=['x', 'index', 'label', 'context']),
         context=context
@@ -3503,7 +3513,8 @@ def array_filter(data, condition, context=UNSET) -> ProcessBuilder:
     :return: An array filtered by the specified condition. The number of elements are less than or equal
         compared to the original array.
     """
-    return _process('array_filter', 
+    return _process(
+        "array_filter",
         data=data,
         condition=build_child_callback(condition, parent_parameters=['x', 'index', 'label', 'context']),
         context=context
@@ -4056,7 +4067,8 @@ def filter_labels(data, condition, dimension, context=UNSET) -> ProcessBuilder:
         system and resolution) remain unchanged, except that the given dimension has less (or the same) dimension
         labels.
     """
-    return _process('filter_labels', 
+    return _process(
+        "filter_labels",
         data=data,
         condition=build_child_callback(condition, parent_parameters=['value', 'context']),
         dimension=dimension,
@@ -4156,7 +4168,8 @@ def fit_curve(data, parameters, function, ignore_nodata=UNSET) -> ProcessBuilder
 
     :return: An array with the optimal values for the parameters.
     """
-    return _process('fit_curve', 
+    return _process(
+        "fit_curve",
         data=data,
         parameters=parameters,
         function=build_child_callback(function, parent_parameters=['x', 'parameters']),
@@ -4704,7 +4717,8 @@ def merge_cubes(cube1, cube2, overlap_resolver=UNSET, context=UNSET) -> ProcessB
     :return: The merged data cube. See the process description for details regarding the dimensions and
         dimension properties (name, type, labels, reference system and resolution).
     """
-    return _process('merge_cubes', 
+    return _process(
+        "merge_cubes",
         cube1=cube1,
         cube2=cube2,
         overlap_resolver=(build_child_callback(overlap_resolver, parent_parameters=['x', 'y', 'context']) if overlap_resolver not in [None, UNSET] else overlap_resolver),
@@ -4903,7 +4917,8 @@ def predict_curve(parameters, function, dimension, labels=UNSET) -> ProcessBuild
     :return: A data cube with the predicted values with the provided dimension `dimension` having as many
         labels as provided through `labels`.
     """
-    return _process('predict_curve', 
+    return _process(
+        "predict_curve",
         parameters=parameters,
         function=build_child_callback(function, parent_parameters=['x', 'parameters']),
         dimension=dimension,
@@ -4994,7 +5009,8 @@ def reduce_dimension(data, reducer, dimension, context=UNSET) -> ProcessBuilder:
         dimensions decreases by one. The dimension properties (name, type, labels, reference system and resolution)
         for all other dimensions remain unchanged.
     """
-    return _process('reduce_dimension', 
+    return _process(
+        "reduce_dimension",
         data=data,
         reducer=build_child_callback(reducer, parent_parameters=['data', 'context']),
         dimension=dimension,
@@ -5225,7 +5241,8 @@ def sar_backscatter(data, coefficient=UNSET, elevation_model=UNSET, mask=UNSET,
     :return: Backscatter values corresponding to the chosen parametrization. The values are given in linear
         scale.
     """
-    return _process('sar_backscatter', 
+    return _process(
+        "sar_backscatter",
         data=data,
         coefficient=coefficient,
         elevation_model=elevation_model,

openeo/rest/job.py

@@ -3,20 +3,16 @@
 import datetime
 import json
 import logging
+import shutil
 import time
 import typing
 from pathlib import Path
 from typing import Dict, List, Optional, Union
 
 import requests
-import shutil
 
 from openeo.internal.documentation import openeo_endpoint
-from openeo.internal.jupyter import (
-    VisualDict,
-    render_component,
-    render_error,
-)
+from openeo.internal.jupyter import VisualDict, render_component, render_error
 from openeo.internal.warnings import deprecated, legacy_alias
 from openeo.rest import (
     DEFAULT_DOWNLOAD_CHUNK_SIZE,

tests/internal/processes/test_generator.py

@@ -284,7 +284,7 @@ def apply_dimension(data, dimension, process):
 
             :return: Data cube
             """
-            return _process('apply_dimension', 
+            return _process('apply_dimension',
                 data=data,
                 dimension=dimension,
                 process=build_child_callback(process, parent_parameters=['data'])
@@ -332,7 +332,7 @@ def apply(data, process=UNSET):
 
             :return: Data cube
             """
-            return _process('apply', 
+            return _process('apply',
                 data=data,
                 process=(build_child_callback(process, parent_parameters=['data']) if process not in [None, UNSET] else process)
             )'''

tests/rest/test_job.py

@@ -12,7 +12,12 @@
 
 import openeo
 import openeo.rest.job
-from openeo.rest import JobFailedException, OpenEoApiPlainError, OpenEoClientException, DEFAULT_DOWNLOAD_CHUNK_SIZE
+from openeo.rest import (
+    DEFAULT_DOWNLOAD_CHUNK_SIZE,
+    JobFailedException,
+    OpenEoApiPlainError,
+    OpenEoClientException,
+)
 from openeo.rest.job import BatchJob, ResultAsset
 from openeo.rest.models.general import Link
 from openeo.rest.models.logs import LogEntry