之前一直用的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)