from airflow import DAG from airflow.operators.dummy_operator import DummyOperator from airflow.operators.bash_operator import BashOperator from datetime import datetime, timedelta with DAG(dag_id='bash_dag', schedule_interval="@once", start_date=datetime(2020, 1, 1), catchup=False) as dag: # Task 1 dummy_task = DummyOperator(task_id='dummy_task') # Task 2 bash_task = BashOperator(task_id='bash_task', bash_command="/usr/local/airflow/dags/command.sh ", xcom_push=True) dummy_task >> bash_task