Как получить доступ к значениям конфигурации при внешнем запуске Airflow DAG? - PullRequest
Новая
       25

Как получить доступ к значениям конфигурации при внешнем запуске Airflow DAG?

0 голосов
/ 01 октября 2019

Согласно https://airflow.apache.org/api.html я могу вызвать DAG Airflow следующим образом: 

curl -X POST \
  http://localhost:8080/api/experimental/dags/<DAG_ID>/dag_runs \
  -H 'Cache-Control: no-cache' \
  -H 'Content-Type: application/json' \
  -d '{"conf":"{\"key\":\"value\"}"}'

Мне кажется, это нормально, но я не могу понять, как получить доступ к key /value материал в передаваемом объекте conf.

Я пробовал это: 

something = dag.params.get("key", "unknown")

Но, похоже, это не работает.

Кто-нибудьзнаете, как это сделать?

...