Я пытаюсь написать модульные тесты на python для тестирования конвейера Airflow DAG.Я видел менее нескольких примеров для модульных тестов на воздушном потоке, при этом наиболее полезным является следующее:
https://blog.usejournal.com/testing-in-airflow-part-1-dag-validation-tests-dag-definition-tests-and-unit-tests-2aa94970570c
Для моего теста я хочу использовать mock.patchдля каждого DAG, когда он инициализируется, до сих пор я инициализировал dag с помощью DagBag (), но я нахожу, что этот способ насмешки либо невозможен, либо крайне неэффективен, с вызовом DagBag () для каждого тестируемого DAG.Можно ли инициализировать один DAG за один раз, не вызывая функцию init DagBag?