Столкнувшись с трудностью запустить Dag в Airflow - PullRequest
Новая
       56

Столкнувшись с трудностью запустить Dag в Airflow

0 голосов
/ 27 сентября 2019

Я столкнулся с трудностью запуска Dag в Airflow, сегодня я написал свой первый день, но он не работает, пожалуйста, помогите мне, я запускаю пример DAG с id: example_bash_operator, он работает отлично (не отображается в папке dag воздушного потокано при запуске пути в cmd указан путь к папке с dag, который я создаю сам), но когда я создаю свой скрипт на python dag, он получает ошибку введите описание изображения здесь при запуске.

location: dags_folder = / home / aizhar / airflow / dags

myfilename: myfirstdag = / home / aizhar / airflow / dags / myfirstdag 

dag = DAG(
  dag_id='firstdag',
    default_args=args,
    schedule_interval='*/5 * * * *',
    #dagrun_timeout=timedelta(minutes=60),
)

1 Ответ

0 голосов
/ 28 сентября 2019

добавить задачу в DAG.Вы не можете запустить пустой DAG.

Примерно так: 

DummyOperator(task_id='dummy', dag=dag)

Обязательно импортируйте DummyOperator.

...