From 240b57e173e69e0b4847a7d2a584aa4fc049a73d Mon Sep 17 00:00:00 2001
From: leggerf <41438017+leggerf@users.noreply.github.com>
Date: Fri, 26 Jan 2024 11:12:38 +0100
Subject: [PATCH] Update dags_airflow_fede_k8sexecutor.py

---
 dags_airflow_fede_k8sexecutor.py | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py
index 9dadb30..86d6064 100644
--- 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,10 +205,10 @@ 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(
@@ -217,7 +216,7 @@ def other_namespace_task():
                     containers=[
                         k8s.V1Container(
                             name="base",
-                            image=f"{worker_container_repository}:{worker_container_tag}",
+                            image=f"{repository}:{tag}",
                         ),
                     ]
                 )