如何设置默认 dag 触发器配置 json

Gun*_*der 6 airflow

当在气流中触发 dag 时,会出现一个窗口,通过该窗口我可以以 json 格式向 dag 提供参数。这看起来像下面这样: 在此输入图像描述

这个 json 始终为空,我必须知道可以将哪些参数传递给 dag。相反,我希望能够预先填充此 json,以便当另一个用户尝试触发 dag 时,他可以简单地更改为 json 的值,而不必先查看 dags 代码。

在当前版本(2.0.0)的气流中,有什么方法可以做到这一点吗?

Евг*_*й М 14

在 Airflow 2.1.0 上,可以设置默认参数,如下所示:

dag = DAG(dag_id="my_dag",
          schedule_interval=None,
          default_args={'retries': 3, 'retry_delay': timedelta(seconds=20)},
          catchup=False,
          tags=['maintenance'],
          params={"description": ""}  #Set parameters as a dictionary
)
Run Code Online (Sandbox Code Playgroud)

在 thrigger UI 中,它看起来像这样:
在此输入图像描述

  • 这是指导文档:https://airflow.apache.org/docs/apache-airflow/stable/concepts/params.html (3认同)

kax*_*xil 0

不,目前不支持——至少对于 Airflow 2.0.0 来说是这样