The scheduler does not appear to be running. Last heartbeat was received .
The DAGs list may not update, and new tasks will not be scheduled.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 | from airflow.operators.bash_operator import BashOperator
from airflow import DAG
from datetime import datetime, timedelta
args = {
'owner': 'liangning',
'start_date': datetime(2022,4,1),
'email': 'dayuan.li@traxretail.com',
'email_on_failure': False,
'email_on_retry': False,
'retries': 3,
'retry_delay': timedelta(minutes=1),
}
dag = DAG(
dag_id='UL_new_app_response_monitoring',
default_args=args,
schedule_interval='01 01-10/3 * * *',
dagrun_timeout=timedelta(minutes=120))
t1=BashOperator(task_id="UL_new_app_response_monitoring",bash_command='cd /usr/local/airflow/dags/bi_etl/bi_project_airflow/project_common/;nohup python unilever_new_app/response_monitoring.py &',dag=dag)
|