1

我正在使用 Airflow 并且在安排我的 DAG 时遇到问题。我有一个 DAG，我想在每个星期日 00:00 运行，这是我的代码

args = {
'owner': 'rsabbir',
'depends_on_past': False,
'start_date': datetime(2018, 2, 22, 00, 00),
'retry_delay': timedelta(minutes=1)
}

dag = DAG(
    dag_id='DAG_column_encoding', default_args=args, schedule_interval='* * * * 0')

我尝试使用与上周不同的“start_date”，但该任务在周末没有运行。还有另一个 DAG，我想在每天的特定时间（凌晨 4:30）运行，我有这个代码。

args = {
'owner': 'rsabbir',
'depends_on_past': False,
'start_date': datetime(2018, 2, 21, 00, 00),
'retry_delay': timedelta(minutes=1)
}

dag = DAG(
    dag_id='DAG_vacuum_tables', default_args=args, schedule_interval='30 4 * * */1')

他们都没有按预期工作。我已经阅读了 Airflow 文档，但不了解这些不同的调度案例是如何工作的。

谁能给我一个关于这些“start_date”和“schedule_interval”如何在气流中实际协同工作的简要想法？有没有其他有效的方法来处理气流中的这两个参数？

4

0 回答 0