Size: a a a

2020 July 22

ДН

Дмитрий Негреев... in Airflow
а, ну ясно)
ладно, PV и git-sync пока мне в помощь)
источник

DS

Dimitriy Scherbenko in Airflow
Всем привет! Помогите, пожалуйста, разобраться в проблеме. Есть даг, который обращается к .py файлу при помощи BashOperator.

Сам .py файл протестирован и работает нормально.

При тестировании дага при помощи  python даг.py отрабатывает, но ничего не происходит.
источник

ИХ

Ильяс Хакиев... in Airflow
Dimitriy Scherbenko
Всем привет! Помогите, пожалуйста, разобраться в проблеме. Есть даг, который обращается к .py файлу при помощи BashOperator.

Сам .py файл протестирован и работает нормально.

При тестировании дага при помощи  python даг.py отрабатывает, но ничего не происходит.
Как минимум нужен код))
источник

DS

Dimitriy Scherbenko in Airflow
Ильяс Хакиев
Как минимум нужен код))
я только начал изучать этот продукт, поэтому не претендую на красоту и грацию)
источник

С

Сюткин in Airflow
А под каким пользователем у тебя airflow?
источник

С

Сюткин in Airflow
Он очевидно не может достучаться до файла
источник

С

Сюткин in Airflow
Закинь файл не в хомяк а куда-нибудь в общую папку
источник

AM

Alexander Millin in Airflow
Dimitriy Scherbenko
Всем привет! Помогите, пожалуйста, разобраться в проблеме. Есть даг, который обращается к .py файлу при помощи BashOperator.

Сам .py файл протестирован и работает нормально.

При тестировании дага при помощи  python даг.py отрабатывает, но ничего не происходит.
python даг.py и не должен работать
источник

С

Сюткин in Airflow
Да и баш команда то неверная
источник

С

Сюткин in Airflow
Ктож там только py файл указывает
источник

GG

George Gaál in Airflow
chmod + x и шебанг в начале - тогда ок должно быть
источник

DS

Dimitriy Scherbenko in Airflow
вот сейчас сделал так airflow trigger_dag tbl_rides_insert и получил ошибку Dag id tbl_rides_insert not found in DagModel
источник

DS

Dimitriy Scherbenko in Airflow
Сюткин
Да и баш команда то неверная
А как надо? Брал пример из интернета. Мне сейчас любая обратная связь полезна
источник

DS

Dimitriy Scherbenko in Airflow
Dimitriy Scherbenko
вот сейчас сделал так airflow trigger_dag tbl_rides_insert и получил ошибку Dag id tbl_rides_insert not found in DagModel
Хотя в шедулере он есть
источник

С

Сюткин in Airflow
С башем вообще не работал?)
Ну создай там sh к примеру и вызывай его


А вообще для питона придумали питоноператор
источник

С

Сюткин in Airflow
Хотя я питон вызываю через sshexecute в основном ибо airflow на одной тачке а скрипты на другой
источник

DS

Dimitriy Scherbenko in Airflow
то есть вот так будет работать?

python_task = PythonOperator(
   task_id='python_task',
   python_callable=file1.py,
   dag=dag
)
источник

С

Сюткин in Airflow
Истина скрыта в практике, попробуй сын мой
источник

DS

Dimitriy Scherbenko in Airflow
Сюткин
Хотя я питон вызываю через sshexecute в основном ибо airflow на одной тачке а скрипты на другой
у меня сейчас на одной тачке
источник

AM

Alexander Millin in Airflow
Dimitriy Scherbenko
то есть вот так будет работать?

python_task = PythonOperator(
   task_id='python_task',
   python_callable=file1.py,
   dag=dag
)
python_callable - это функция, а не файл
источник