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

Question

在气流中触发 dag 时，有一个窗口，我可以通过该窗口以 json 格式将参数设置为 dag。如下所示：

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

在当前版本（2.0.0）的气流中有什么方法可以做到这一点？

标签： airflow

Answer 1

在 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
)

在触发 UI 中，它看起来像这样：