diff --git a/openeo/extra/job_management.py b/openeo/extra/job_management.py index 603eae9c0..397759167 100644 --- a/openeo/extra/job_management.py +++ b/openeo/extra/job_management.py @@ -100,6 +100,7 @@ def _normalize_df(self, df: pd.DataFrame) -> pd.DataFrame: df["geometry"] = df["geometry"].apply(shapely.wkt.loads) return df + # TODO: long method with deep nesting. Refactor it to make it more readable. def run_jobs(self, df: pd.DataFrame, start_job: Callable, output_file: Path): """Runs jobs, specified in a dataframe, and tracks parameters.