Я использую airflow
и поднимаю его, используя docker
.
Один из создаваемых мной контейнеров - это postgres
DB, где хранятся все мои DAG
s и их информация.
Моя проблема в том, что я пытаюсь написать тесты для некоторых из DAG
s, и для этого мне нужно иметь возможность получить DAG
s.
Мой вопрос заключается в том, как мне написать скрипт, который запускает код из postgres
контейнер, даже когда я запускаю его локально на моей машине?
Так, например, если я хочу получить все DAG
с помощью метода DagBag
, как я могу убедиться, что я вызываю его в airflow postgres
контейнере?