clear_task_bug_dag_1.0

gistfile1.txt

from airflow import DAG, utils
from airflow.operators.dummy_operator import DummyOperator
from datetime import date, datetime, time, timedelta


today = datetime.today()
# Round to align with the schedule interval
START_DATE = today.replace(minute=0, second=0, microsecond=0)
DAG_NAME = 'clear_task_bug_dag_1.0'

default_args = {
    'owner': 'sanand',
    'depends_on_past': False,
    'start_date': START_DATE,
    'email': ['sanand@agari.com'],
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1,
}
cron_schedule = '*/10 * * * *'
dag = DAG(DAG_NAME, schedule_interval=cron_schedule,
          default_args=default_args
          )

d1 = DummyOperator(
  task_id         = 'd1',
  dag             = dag
)
d2 = DummyOperator(
  task_id         = 'd2',
  dag             = dag
)
d3 = DummyOperator(
  task_id         = 'd3',
  dag             = dag
)
d4 = DummyOperator(
  task_id         = 'd4',
  dag             = dag
)
d2.set_upstream(d1)
d3.set_upstream(d2)
d4.set_upstream(d3)