时间戳

首页 > 解决方案 > 气流调度每月作业

airflow - 气流调度每月作业

问题描述

我想安排一个每月在今天的同一天运行的每月作业。我希望今天是第一次运行。例如，今天是 11/2，时间是上午 10 点。我如何安排每月 2 日上午 11 点运行的月度作业，必须首先运行 11/2。

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2020, 11, 1,22,00),
    'email': "myemail@abc.com",
    'email_on_failure': True,
    'email_on_success': True,
    'retries': 0
}   

def print_hello():
    today = date.today()
    print("Today's date:", today)
    return 'Hello world! Monthly Run'

dag = DAG('dummy_monthly', description='Simple tutorial DAG',
          schedule_interval='11 00 2 * *',
          start_date=datetime(2020, 11,2), catchup=False)

标签： airflowairflow-scheduler

解决方案

更改schedule_interval为00 11 2 * *

推荐阅读