1

我正在探索apache airflow 1.8。我很好奇有没有办法将参数传递给DAGs或taskswhile backfilling？

这是我正在寻找的东西，

airflow backfill My_DAG -s some_date -e end_date argument_for_t1 argument_for_t2

或者它可能是arrayargs。

有什么方法可以传递参数吗？我搜索了很多，但找不到任何东西。

4

2 回答 2

2

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

但是，您可以转到 DagBag 文件夹并将参数提供给 dag 对象（更改/修复现有 dag），然后回填 DAG

于 2017-04-07T07:04:46.697 回答
0

我遇到了可以使用设置变量的解决方案airflow variables -s my_var="some value"

现在我可以访问my_var应用程序的任何位置。

有关更多选项，请检查cli

于 2017-04-13T15:15:16.067 回答