Update dags_airflow_fede_k8sexecutor.py

interTwin-eu · Jan 26, 2024 · 85aa523 · 85aa523
1 parent 240b57e
commit 85aa523
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py
@@ -134,7 +134,7 @@ def test_volume_mount():
                     ],
                     volumes=[
                         k8s.V1Volume(
-                            name="shared-empty-dir", 
+                            name="shared-empty-dir",
                             empty_dir=k8s.V1EmptyDirVolumeSource(),
                         ),
                     ],
@@ -202,12 +202,10 @@ def other_namespace_task():
         other_ns_task = other_namespace_task()
 
         #############################################################
-        # Define config for task: pod with image
+        # Define config for task: pod with image 
         #############################################################
 
-        repository = conf.get(
-            "kubernetes_executor", "worker_container_repository"
-        )
+        repo = conf.get("kubernetes_executor", "worker_container_repository")
         tag = conf.get("kubernetes_executor", "worker_container_tag")
 
         kube_exec_config_image = {
@@ -216,7 +214,7 @@ def other_namespace_task():
                     containers=[
                         k8s.V1Container(
                             name="base",
-                            image=f"{repository}:{tag}",
+                            image=f"{repo}:{tag}",
                         ),
                     ]
                 )