# ----------------------------------------------------------; # author : michael.mill@syneru.com # date : 21/10/2021 # # objectives # { # - develop shell / sh script for PHP procedure. # # } # ----------------------------------------------------------; 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="/home/wyr/airflow/sh/command.sh", xcom_push=True) dummy_task >> bash_task