0

我创建了一些DAGs,并尝试将其放在调度程序上。我想在 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

谁能指出我做错了什么?

4

0 回答 0