当在气流中触发 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)
归档时间: |
|
查看次数: |
8746 次 |
最近记录: |