Как запустить код из контейнеров с воздушным потоком? - PullRequest
0 голосов
/ 17 марта 2020

Я использую airflow и поднимаю его, используя docker.

Один из создаваемых мной контейнеров - это postgres DB, где хранятся все мои DAG s и их информация.

Моя проблема в том, что я пытаюсь написать тесты для некоторых из DAG s, и для этого мне нужно иметь возможность получить DAG s.

Мой вопрос заключается в том, как мне написать скрипт, который запускает код из postgres контейнер, даже когда я запускаю его локально на моей машине?

Так, например, если я хочу получить все DAG с помощью метода DagBag, как я могу убедиться, что я вызываю его в airflow postgres контейнере?

...