basic_workflow_airflow

basic_workflow_airflow.py

#import 
from datetime import timedelta
from airflow import DAG
from datetime import datetime,timedelta
from airflow.operators.dummy_operator import DummyOperator
#import dummyoperator airflow

# define defult dag

default_args={
    'owner':'admin',
    'depends_on_past':False,
    'start_date':   datetime(2022,3,9),
    'retries':0
}

dag=DAG(dag_id='DAG-1',default_args=default_args,catchup=False,schedule_interval="@once")

#creating task

start=DummyOperator(task_id='start',dag=dag) 
end=DummyOperator(task_id='end',dag=dag)

#dependency
start >> end