代码之家  ›  专栏  ›  技术社区  ›  moirK

无法使气流DAG在每天的特定时间运行

  •  0
  • moirK  · 技术社区  · 5 年前

    我正试图安排一个气流DAG,但无法成功地这样做。我有一个有效的开始日期。我想安排它运行在每天早上5:30,但我不得不手动触发它在过去几天。

    以下是我的计划间隔: schedule_interval='30 5 0 0 0' . 我也尝试过这样一种不同的语法: schedule_interval='30 5 * * *' ,但无法使其工作。下面是我的完整代码:

    default_dag_args = {
        'start_date': datetime.datetime(2020, 9, 15),
    }
    
    with models.DAG(
            'data_dump',
            schedule_interval='30 5 0 0 0',
            default_args=default_dag_args) as dag:
      
        hello = bash_operator.BashOperator(
                task_id='hello',
                bash_command='echo Hello.')
    
        goodbye_bash = bash_operator.BashOperator(
            task_id='bye',
            bash_command='echo Goodbye.')
    
        hello >> goodbye_bash
    

    我开始怀疑了,是吗 schedule_interval europe-west1-b

    我需要帮助找出我的代码有什么问题,以及如何安排一个正确的DAG,并将感谢您的回应。提前谢谢。

    0 回复  |  直到 5 年前
        1
  •  1
  •   kaxil    5 年前

    30 5 * * * 正确吗 scheduler_interval .

    你可以用老一点的测试 start_date 具体如下:

    with models.DAG(
            'data_dump',
            schedule_interval='30 5 0 0 0',
            start_date=datetime.datetime(2020, 9, 1)) as dag: