Update dags_airflow_fede_rucio_k8soperator.py

interTwin-eu · Feb 1, 2024 · ea179ea · ea179ea
1 parent e2edcab
commit ea179ea
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/dags_airflow_fede_rucio_k8soperator.py b/dags_airflow_fede_rucio_k8soperator.py
@@ -2,23 +2,22 @@
 
 from airflow import DAG
 from airflow.contrib.operators.kubernetes_pod_operator import KubernetesPodOperator
-
 from kubernetes.client import models as k8s
 
 default_args = {
-    'owner': 'airflow',
-    'start_date': datetime(2020, 1, 1),
+    "owner": "airflow",
+    "start_date": datetime(2020, 1, 1),
 }
 
 dag = DAG(
-    'rucio_operator', default_args=default_args, tags=["fede"], schedule_interval=None
+    "rucio_operator", default_args=default_args, tags=["fede"], schedule_interval=None
 )
 
 repo = "leggerf/rucio-intertwin"
 tag = "0.0.0"
 
 k = KubernetesPodOperator(
-    namespace='airflow',
+    namespace="airflow",
     image=f"{repo}:{tag}",  # image="ubuntu:16.04",
     image_pull_secrets=[k8s.V1LocalObjectReference("dockerhub")],
     # image_pull_policy="Always",
@@ -31,7 +30,7 @@
     is_delete_operator_pod=False,
     hostnetwork=False,
     startup_timeout_seconds=900,
-    dag=dag
+    dag=dag,
 )
 
 # define DAG pipeline