Update dags_airflow_fede_rucio.py

interTwin-eu · Jan 30, 2024 · 2fad06e · 2fad06e
1 parent 8d891a5
commit 2fad06e
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/dags_airflow_fede_rucio.py b/dags_airflow_fede_rucio.py
@@ -4,13 +4,12 @@
 from __future__ import annotations
 
 import logging
-import os
-from pathlib import Path
+# import os
+# from pathlib import Path
 
 import pendulum
-from airflow.configuration import conf
+# from airflow.configuration import conf
 from airflow.decorators import task
-from airflow.example_dags.libs.helper import print_stuff
 from airflow.models.dag import DAG
 
 log = logging.getLogger(__name__)
@@ -51,6 +50,7 @@
                         k8s.V1Container(
                             name="base",
                             image=f"{repo}:{tag}",
+                            command=["pwd"],
                         ),
                     ],
                     image_pull_secrets=[
@@ -71,7 +71,6 @@
             task_id="task_rucio",
         )
         def rucio_task():
-            print_stuff()
             log.info("Using image " + f"{repo}:{tag}")
 
         rucio_task = rucio_task()