EJR is still optional (C-SCALE) #632

Open-EO · Jan 9, 2024 · e0a9743 · e0a9743
1 parent e7cbce5
commit e0a9743
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/openeogeotrellis/deploy/kube.py b/openeogeotrellis/deploy/kube.py
@@ -49,7 +49,7 @@ def on_started():
 
     from openeogeotrellis.backend import GeoPySparkBackendImplementation
 
-    backend_implementation = GeoPySparkBackendImplementation()
+    backend_implementation = GeoPySparkBackendImplementation(use_job_registry=bool(get_backend_config().ejr_api))
     app = build_app(backend_implementation=backend_implementation)
 
     #https://github.com/Open-EO/openeo-python-driver/issues/242

diff --git a/openeogeotrellis/job_tracker_v2.py b/openeogeotrellis/job_tracker_v2.py
@@ -599,7 +599,8 @@ def main(self, *, args: Optional[List[str]] = None):
                 requests_session = requests_with_retry(total=3, backoff_factor=2)
 
                 # Elastic Job Registry (EJR)
-                elastic_job_registry = get_elastic_job_registry(requests_session)
+                elastic_job_registry = (get_elastic_job_registry(requests_session) if get_backend_config().ejr_api
+                                        else None)
 
                 # YARN or Kubernetes?
                 app_cluster = args.app_cluster