我创建了一些DAG
s,并尝试将其放在调度程序上。我想在 24 小时后运行 DAG 中的所有任务。我试图做这样的事情。
DEFAULT_ARGS = {
'owner' : 'mubin',
'depends_on_past' : False,
'start_date' : datetime(2017, 4, 24, 14, 30),
'retries' : 5,
'retry_delay' : timedetla(1),
}
SCHEDULE_INTERVAL = timedelta(minutes=1440)
# SCHEDULE_INTERVAL = timedelta(hours=24)
# SCHEDULE_INTERVAL = timedelta(days=1)
dag = DAG('StandardizeDataDag',
default_args = DEFAULT_ARGS,
schedule_interval = SCHEDULE_INTERVAL
)
我试图设置不同的间隔,但没有任何工作。但是,如果我尝试重置 dbairflow resetdb -y
然后运行airflow initdb
,它会工作一次。然后在那之后,调度程序无法运行它。
气流版本:v1.8.0
PS。airflow scheduler
通过执行root
谁能指出我做错了什么?