Airflow - DAGs

from airflow.operators.bash_operator import BashOperator
from airflow import DAG
from datetime import datetime, timedelta



args = {
    'owner': 'lidayuan',
    'start_date': datetime(2022, 4, 3),
    'email': 'gaoqiang@lenztechretail.com',
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 3,
    'retry_delay': timedelta(minutes=1),
}

dag = DAG(
    dag_id='ul_new_app_monv2',
    default_args=args,
    schedule_interval='01 01,04,07,10 * * *',
    dagrun_timeout=timedelta(minutes=200))



ul_new_app_mon=BashOperator(task_id="ul_new_app_monv2",bash_command='cd /usr/local/airflow/dags/bi_etl/bi_project_airflow/project_common/;nohup python unilever_new_app/response_monitoring.py &',dag=dag)

DAG: ul_new_app_monv2

schedule: 01 01,04,07,10 * * *

ul_new_app_monv2