Issue #165 update to new job_option handling in connection.create_job

Author: soxofaan

CHANGELOG.md

@@ -6,6 +6,10 @@ The format is roughly based on [Keep a Changelog](https://keepachangelog.com/en/
 
 <!-- start-of-changelog -->
 
+## unreleased
+
+- Update to harmonized `job_option`/`additional` handling in `Connection.create_job` ([#165](https://github.com/Open-EO/openeo-aggregator/issues/165), [Open-EO/openeo-python-client#683](https://github.com/Open-EO/openeo-python-client/issues/683))
+
 ## 0.39.0
 
 - More advanced process-graph splitting for cross-backend execution: not limited to splitting off `load_collection` nodes, but cut deeper into the graph. ([#150](https://github.com/Open-EO/openeo-aggregator/issues/150))

setup.py

@@ -34,7 +34,7 @@
     install_requires=[
         "requests",
         "attrs",
-        "openeo>=0.27.0",
+        "openeo>=0.36.0",
         "openeo_driver>=0.107.4.dev",
         "flask~=2.0",
         "gunicorn~=20.0",

src/openeo_aggregator/backend.py

@@ -866,13 +866,11 @@ def _create_job_standard(
         process_graph = self.processing.preprocess_process_graph(process_graph, backend_id=backend_id)
 
         if job_options:
-            additional = {k: v for k, v in job_options.items() if not k.startswith("_agg_")}
-        else:
-            additional = None
+            job_options = {k: v for k, v in job_options.items() if not k.startswith("_agg_")}
 
         if get_backend_config().job_options_update:
             # Allow fine-tuning job options through config
-            additional = get_backend_config().job_options_update(job_options=additional, backend_id=backend_id)
+            job_options = get_backend_config().job_options_update(job_options=job_options, backend_id=backend_id)
 
         con = self.backends.get_connection(backend_id)
         with con.authenticated_from_request(request=flask.request, user=User(user_id=user_id)), con.override(
@@ -885,7 +883,7 @@ def _create_job_standard(
                     description=metadata.get("description"),
                     plan=metadata.get("plan"),
                     budget=metadata.get("budget"),
-                    additional=additional,
+                    job_options=job_options,
                 )
             except OpenEoApiError as e:
                 for exc_class in [ProcessGraphMissingException, ProcessGraphInvalidException]:

tests/test_views.py

@@ -1953,7 +1953,7 @@ def post_jobs(request: requests.Request, context):
         ).assert_status_code(201)
         assert res.headers["Location"] == f"http://oeoa.test/openeo/1.0.0/jobs/{expected}-th3j0b"
         assert res.headers["OpenEO-Identifier"] == f"{expected}-th3j0b"
-        assert jobs == [{"process": {"process_graph": pg}}]
+        assert jobs == [{"process": {"process_graph": pg}, "job_options": {}}]
 
         assert (backend1_post_jobs.call_count, backend2_post_jobs.call_count) == {
             "b1": (1, 0),