Size: a a a

2021 March 04

ST

Serg T in Airflow
Justice For All
apache-airflow-providers-ssh - это тоже самое что и apache-airflow[ssh] ?
непонятно 1. http://airflow.apache.org/docs/apache-airflow/1.10.3/installation.html
2. https://pypi.org/project/apache-airflow-providers-ssh/
источник

ST

Serg T in Airflow
Justice For All
apache-airflow-providers-ssh - это тоже самое что и apache-airflow[ssh] ?
и то и то провайдер
источник

JF

Justice For All in Airflow
Serg T
и то и то провайдер
похоже что это одно и тоже. по крайней мере, когда установил apache-airflow[telegram], то у меня появился установленный пакет apache-airflow-providers-telegram
источник

ST

Serg T in Airflow
Justice For All
похоже что это одно и тоже. по крайней мере, когда установил apache-airflow[telegram], то у меня появился установленный пакет apache-airflow-providers-telegram
хз, может версии отличаются, я устанавливаю как написал выше
источник

SC

Stanislav Chernov in Airflow
Привет!
А кто может подсказать, почему через API - GET-запрос работает, а POST - нет ?

Собственно, получаю список прошлых запусков
curl -X GET 'http://URL:8080/api/v1/dags/np_run_test_task_1_3-20_A_A_A/dagRuns' -H 'Cache-Control: no-cache' -H 'Content-Type: application/json' --user 'admin:admin'

Меняю GET на POST, чтобы запустить даг сейчас - получаю еррор

curl -X POST 'http://URL:8080/api/v1/dags/np_run_test_task_1_3-20_A_A_A/dagRuns' -H 'Cache-Control: no-cache' -H 'Content-Type: application/json' --user 'admin:admin'

{
 "detail": "None is not of type 'object'",
 "status": 400,
 "title": "Bad Request",
 "type": "https://airflow.apache.org/docs/2.0.1/stable-rest-api-ref.html#section/Errors/BadRequest"
}

Может быть нужно какие то еще параметры передавать ?
Но в документации ни слова про обязательность этого, только dag_id ...
http://apache-airflow-docs.s3-website.eu-central-1.amazonaws.com/docs/apache-airflow/latest/stable-rest-api-ref.html#operation/post_dag_run
источник

А

Адиль in Airflow
Stanislav Chernov
Привет!
А кто может подсказать, почему через API - GET-запрос работает, а POST - нет ?

Собственно, получаю список прошлых запусков
curl -X GET 'http://URL:8080/api/v1/dags/np_run_test_task_1_3-20_A_A_A/dagRuns' -H 'Cache-Control: no-cache' -H 'Content-Type: application/json' --user 'admin:admin'

Меняю GET на POST, чтобы запустить даг сейчас - получаю еррор

curl -X POST 'http://URL:8080/api/v1/dags/np_run_test_task_1_3-20_A_A_A/dagRuns' -H 'Cache-Control: no-cache' -H 'Content-Type: application/json' --user 'admin:admin'

{
 "detail": "None is not of type 'object'",
 "status": 400,
 "title": "Bad Request",
 "type": "https://airflow.apache.org/docs/2.0.1/stable-rest-api-ref.html#section/Errors/BadRequest"
}

Может быть нужно какие то еще параметры передавать ?
Но в документации ни слова про обязательность этого, только dag_id ...
http://apache-airflow-docs.s3-website.eu-central-1.amazonaws.com/docs/apache-airflow/latest/stable-rest-api-ref.html#operation/post_dag_run
🤝, А где тело запроса для POST?
источник

SC

Stanislav Chernov in Airflow
Адиль
🤝, А где тело запроса для POST?
А какие нужно передать параметры?
источник

А

Адиль in Airflow
источник

А

Адиль in Airflow
Там в request body есть параметры в json
источник

SC

Stanislav Chernov in Airflow
Там не отмечено что они обязательны
источник

А

Адиль in Airflow
Ну логично же, что как минимум execution date нужен
источник

А

Адиль in Airflow
У тебя в запросе об этом ни слова
источник

SC

Stanislav Chernov in Airflow
If you try to modify the field of an existing object, the request fails with an BAD_REQUEST error. This together with DAG_ID are a unique key.
источник

SC

Stanislav Chernov in Airflow
Если я укажу не то что у меня в даге - то не сработает, верно ?
источник

А

Адиль in Airflow
Речь про conf ?
источник

SC

Stanislav Chernov in Airflow
ППц
источник

SC

Stanislav Chernov in Airflow
добавил в курл -d '{ "execution_date": "2021-03-04T05:21:23Z" }'
источник

SC

Stanislav Chernov in Airflow
сработало 🤦‍♂️
источник

А

Адиль in Airflow
Ну вот)
источник

SC

Stanislav Chernov in Airflow
Спасибо
источник