From 4e0e6b3daff33865a3e78dcf0ca40d30980aa5b2 Mon Sep 17 00:00:00 2001 From: leggerf <41438017+leggerf@users.noreply.github.com> Date: Tue, 6 Feb 2024 12:03:29 +0100 Subject: [PATCH] Update dags_airflow_fede_k8sexecutor.py --- dags_airflow_fede_k8sexecutor.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/dags_airflow_fede_k8sexecutor.py b/dags_airflow_fede_k8sexecutor.py index d34b1a2..46a7927 100644 --- a/dags_airflow_fede_k8sexecutor.py +++ b/dags_airflow_fede_k8sexecutor.py @@ -238,9 +238,11 @@ def other_namespace_task(): ############################################################# # use image from worker node as example - repo = conf.get("kubernetes_executor", "worker_container_repository") - tag = conf.get("kubernetes_executor", "worker_container_tag") - + # repo = conf.get("kubernetes_executor", "worker_container_repository") + # tag = conf.get("kubernetes_executor", "worker_container_tag") + repo = "leggerf/rucio-intertwin" + tag = "0.0.0" + kube_exec_config_image = { "pod_override": k8s.V1Pod( spec=k8s.V1PodSpec(