添加第一个dag时Cloud Composer调度程序出错



我在本地气流上运行了一个DAG。我和Cloud Composer共进午餐,想把我的DAG搬到那里。当添加第一个DAG文件时,调度程序显示此错误:

Traceback(上次调用(:文件"/usr/local/lib/airflow/airflow/models.py",第363行,在process_file中m=imp.load_source(mod_name,filepath(文件"/usr/local/lib/python3.6/imp.py",第172行,在load_source模块中=_加载(规范(文件",第684行,在_load文件"中,第665行,位于_load_unlocked文件中",第674行,在exec_module中文件",第781行,在get_code中文件",第741行,位于source_to_code文件",第219行,在_call_with_frames_removed文件"/home/airflow/gcs/dags/testdag.py",第95行"开始日期":日期时间(2018,12,05(,

这是第95行:

args = {
'owner': 'Airflow',
'start_date': datetime(2018, 12, 05),
'retries': 5,
'retry_delay': timedelta(minutes=5)
}

以前从未遇到过此错误。

如果您想运行DAG并从历史日期进行追赶,那么您可以将过去的日期作为start_date

尝试给出

from datetime import datetime, timedelta
args = {
'owner': 'Airflow',
'provide_context': True,
'depends_on_past': False,
'start_date': datetime.combine(datetime.today(),datetime.min.time()),
'retries': 5,
'retry_delay': timedelta(minutes=5)
}

可能是您在start_date中给出的日期值。尝试在datetime(2018, 12, 05)中仅提供5,然后再次更新DAG文件夹。

最新更新