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.

DAG: test_Mei

schedule: 0 3 0 * * *

test_Mei

Toggle wrap 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
from airflow.operators.bash_operator import BashOperator
from airflow import DAG
from datetime import datetime, timedelta


args = {
    'owner': 'liangning',
    'start_date': datetime(2020, 8, 19),
    'email': 'yanyi.mei@traxretail.com',
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 3,
    'retry_delay': timedelta(minutes=1),
}

dag = DAG(
    dag_id='test_Mei',
    default_args=args,
    schedule_interval='0 3 0 * * *',
    dagrun_timeout=timedelta(minutes=120))


t0 = BashOperator(
    task_id='sleep',
    bash_command='sleep 5',
    retries=3,
    dag=dag)

#青岛啤酒项目 
t1 = BashOperator(
    task_id='test_Mei',
    bash_command='cd /usr/local/airflow/dags/bi_etl/test_Mei/projects_test/;nohup python3 main.py > /usr/local/airflow/logs/test_Mei.txt &', dag=dag)

t0.set_upstream(t1)