测试整个气流DAG而不是单个任务

Question

朋友们，我花了3-4天的时间在谷歌上寻找一些信息来编写python测试用例来测试整个dag (而不是任务)。我什么也没找到。我想知道是否有可能做到这一点，如果是的话，有哪些可用的选择？看起来空气流动并不能提供任何易于使用的东西。

Answer 1

使用以下命令：

airflow dags test dag_id_here 2021-11-10T14:20:00Z

日期必须为过去日期

Answer 2

airflow documentation提供了一些关于如何测试DAG的最佳做法。还有一些关于测试here的其他信息。

comment @n8sty left也是合理的，因为并不总是需要测试端到端的DAG。您可以尝试将单元测试的重点放在测试组成DAG的各个组件上。例如:自定义运算符、python运算符使用的回调函数等。