DAG, похоже, отсутствует, но код виден

Question

У меня есть DAG с тремя задачами, которые работают отлично. Каждая задача - это оператор Python, DAG работает нормально, и я могу просмотреть его, когда функция определена в том же файле, но как только я перемещаю функцию в другой файл, чтобы сделать код более чистым и импортировать ту же функцию в в файле DAG указано, что DAG, похоже, отсутствует. То же самое происходит, когда я нарушаю свой код с помощью оператора Subdag. Что делать? В чем может быть ошибка?

t1 = PythonOperator(
    task_id='abcd',
    provide_context=True,
    python_callable=abcd.efgh,
    dag=dag
)

Answer 1

Если вы еще этого не сделали, попробуйте настроить основные файлы DAG и их зависимости внутри папки Airflow 'DAGS', как показано на рисунке ниже.

Затем импортируйте требуемый файл из соответствующей папки зависимостей в основной файл DAG, используя:

из dependencies_dag1импортировать файл