airflow python3 启动设置

之前一直用的python2版的airflow一直没毛病,很正常,今天把之前的

所有调度任务迁移到python3版,尴尬了😓,不跑了,一直以为是schedule_interval的锅

各种设置后 还是不行,开始怀疑人生,于是开始改start_date

如果要想在schedule_interval设置的时间启动
start_date设置为前一天,如果当期时间已超过schedule_interval会先运行一次

default_args={

'owner':'zz',

'depends_on_past':False,

'start_date':airflow.utils.dates.days_ago(1),

}

修改后开始跑了😆,看了下源码

def days_ago(n, hour=0, minute=0, second=0, microsecond=0):
    """
    Get a datetime object representing `n` days ago. By default the time is
    set to midnight.
    """
    today = datetime.today().replace(
        hour=hour,
        minute=minute,
        second=second,
        microsecond=microsecond)
    return today - timedelta(days=n)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容