当手动触发 DAG 时,有多种方法可以传递配置。它可以从 UI 中完成,通过气流 CLI 使用--conf
参数和使用 REST API。
但是,当使用 cron 表达式调度 DAG 时,DAG 总是会失败,因为 DAG 中的任务需要来自conf
.
是否有可用于为值设置“默认”值的 DAG 级别配置conf
(无需对 Python 代码本身进行空检查并硬编码默认值)
我不想在代码本身中执行此 null 检查的原因是因为我希望conf
尽可能通过 Airflow API 公开键和默认值
当手动触发 DAG 时,有多种方法可以传递配置。它可以从 UI 中完成,通过气流 CLI 使用--conf
参数和使用 REST API。
但是,当使用 cron 表达式调度 DAG 时,DAG 总是会失败,因为 DAG 中的任务需要来自conf
.
是否有可用于为值设置“默认”值的 DAG 级别配置conf
(无需对 Python 代码本身进行空检查并硬编码默认值)
我不想在代码本身中执行此 null 检查的原因是因为我希望conf
尽可能通过 Airflow API 公开键和默认值