airflow - DagBag 没有按预期填充 dag

Question

我想测试我的 dag 以确保它们具有某些默认参数，并确保所有 dag 都没有导入错误。

我正在使用 DagBag 填充 dag，然后遍历每个 dag 并检查每个 dag 的值以确保它们是我想要的。

因为 DagBag 还可以获取气流附带的示例 dag，所以我正在传递参数，include_example = False但是当我这样做时，我意识到我的任何 dag 都没有被拉入 dagbags。

我是否错误地使用了 DagBag？还是在测试时有另一种更好的方法来拉动和检查 dags？

我的代码

def test_no_import_errors():
    dag_bag = DagBag(include_examples=False)
    assert len(dag_bag.import_errors) == 0, "No Import Failures"

标签： airflowdirected-acyclic-graphs

Answer 1

当您构造 DagBag 对象时，您可以传递文件夹列表，DagBag 应该在其中查找 dag 文件。我想这是问题所在