Update dags_airflow_fede_k8sexecutor.py

interTwin-eu · Jan 26, 2024 · 240b57e · 240b57e
1 parent ef4a6fa
commit 240b57e
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py
@@ -15,7 +15,6 @@
 import os
 
 import pendulum
-
 from airflow.configuration import conf
 from airflow.decorators import task
 from airflow.example_dags.libs.helper import print_stuff
@@ -206,18 +205,18 @@ def other_namespace_task():
         # Define config for task: pod with image
         #############################################################
 
-        worker_container_repository = conf.get(
+        repository = conf.get(
             "kubernetes_executor", "worker_container_repository"
         )
-        worker_container_tag = conf.get("kubernetes_executor", "worker_container_tag")
+        tag = conf.get("kubernetes_executor", "worker_container_tag")
 
         kube_exec_config_image = {
             "pod_override": k8s.V1Pod(
                 spec=k8s.V1PodSpec(
                     containers=[
                         k8s.V1Container(
                             name="base",
-                            image=f"{worker_container_repository}:{worker_container_tag}",
+                            image=f"{repository}:{tag}",
                         ),
                     ]
                 )