The docker-compose file to run Airflow in local ( You have to install docker )

marclamberti/docker-airflow

The data pipeline:

# dags/branching_dag.py

from airflow import DAG
from airflow.operators.dummy import DummyOperator

from datetime import datetime

default_args = {
    'start_date': datetime(2020, 1, 1)
}

with DAG('branching', schedule_interval='@daily', default_args=default_args, catchup=False) as dag:

    accurate = DummyOperator(
        task_id='accurate'
    )

    inaccurate = DummyOperator(
        task_id='inaccurate'
    )