Airflow задайте run_id с параметром из конфигурации JSON

Я хочу автоматически установить для run_id более осмысленное имя.

Как я понял, сейчас run_id задается в TriggerDagRunOperator. Я видел в этом потоке предложение по замене TriggerDagRunOperator для данные.

Я также хочу, чтобы изменение применялось при использовании пользовательского интерфейса Airflow.

  1. Можно ли передать run_id из конфига?
  2. Если я изменю оператора, как мне сделать так, чтобы пользовательский интерфейс постоянно использовал этот оператор?

person uriya shavit    schedule 06.10.2020    source источник