From 9b9aea10bf548a697b5b169390909e7b7911338a Mon Sep 17 00:00:00 2001
From: Sara Vallero <svallero@to.infn.it>
Date: Thu, 18 Jan 2024 15:28:16 +0100
Subject: [PATCH] Some cleanup

---
 hello_world_airflow_dag.py                    | 17 ------------
 kubernetes_airflow_dag.py                     | 26 -------------------
 ..._2.py => kubernetes_airflow_dag_example.py |  0
 3 files changed, 43 deletions(-)
 delete mode 100644 hello_world_airflow_dag.py
 delete mode 100644 kubernetes_airflow_dag.py
 rename kubernetes_airflow_dag_2.py => kubernetes_airflow_dag_example.py (100%)

diff --git a/hello_world_airflow_dag.py b/hello_world_airflow_dag.py
deleted file mode 100644
index dec0439..0000000
--- a/hello_world_airflow_dag.py
+++ /dev/null
@@ -1,17 +0,0 @@
-from airflow import DAG
-from airflow.operators.python import PythonOperator
-from datetime import datetime
-
-def helloWorld():
-    print("Hello World")
-
-with DAG(dag_id="hello_world_dag",
-         start_date=datetime(2021,1,1),
-         schedule_interval="@hourly",
-         catchup=False) as dag:
-
-        task1 = PythonOperator(
-                task_id="hello_world",
-                python_callable=helloWorld)
-
-task1
diff --git a/kubernetes_airflow_dag.py b/kubernetes_airflow_dag.py
deleted file mode 100644
index 1df32b4..0000000
--- a/kubernetes_airflow_dag.py
+++ /dev/null
@@ -1,26 +0,0 @@
-import os
-
-import pendulum
-
-from airflow import DAG
-from airflow.decorators import task
-from airflow.example_dags.libs.helper import print_stuff
-from airflow.settings import AIRFLOW_HOME
-
-from kubernetes.client import models as k8s
-
-with DAG(
-    dag_id="example_pod_template_file",
-    schedule=None,
-    start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
-    catchup=False,
-    tags=["example3"],
-) as dag:
-    executor_config_template = {
-        "pod_template_file": os.path.join(AIRFLOW_HOME, "pod_templates/basic_template.yaml"),
-        "pod_override": k8s.V1Pod(metadata=k8s.V1ObjectMeta(labels={"release": "stable"})),
-    }
-
-    @task(executor_config=executor_config_template)
-    def task_with_template():
-        print_stuff()
diff --git a/kubernetes_airflow_dag_2.py b/kubernetes_airflow_dag_example.py
similarity index 100%
rename from kubernetes_airflow_dag_2.py
rename to kubernetes_airflow_dag_example.py