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