2017-04-06 88 views
1

我在探索apache airflow 1.8。我很好奇,有没有办法将参数传递给DAGstasksbackfilling将参数传递给DAG,任务apache airflow

下面是类似的东西,我在寻找,

airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2 

,也可能是参数的个数array

有没有办法传递参数?我搜索了很多,但无法找到任何东西。

回答

0

我对面,我可以使用airflow variables -s my_var="some value"

设置变量的解决方案来

现在我可以在整个应用程序的任何地方访问my_var

更多选项查看cli

+0

如果你有一次一个单一的运行,这是可以接受的。对于具有不同变量的各种并发运行,这是行不通的,因为变量是全局的。 – ilcord

2

回填将重新运行失败/错过/错误配置的DAG,因此没有规定提供命令行参数。

但是,你可以去DagBag文件夹,并给PARAMS到DAG对象(改变/修复现有DAG),然后回填土的DAG