Задача настройки в воздушном потоке DAG ⇐ Python

[Anonymous]

У меня есть сервис, которая генерирует DAG в соответствии с шаблоном и загружает его в git Repo.
Существует контейнер для воздушного потока, используя этот репо в качестве его источника DAG. /> То, что я пробовал:
Для каждого DAG создайте еще один, который запланирован на наборе данных, который оригинал One Outlet, а затем останавливается. Тем не менее, этот DAG никогда не может быть удален, так как он определен в том же файле, что и сгенерированный.

Подробнее здесь: https://stackoverflow.com/questions/796 ... irflow-dag