Воздушный поток запланирован с параметрами конфигурации dag ⇐ Python

[Anonymous]

Я запускаю анализ воздушного потока и пытаюсь запустить его по расписанию. Когда даг запускается планировщиком, даг run_config принимает значение None.
Я пробовал это, но у меня это не сработало — Airflow, как установить значения по умолчанию для dag_run.conf< /p>
Мой код выглядит примерно так

Код: Выделить всё

def parse_conf(**kwargs):
print(f"dag run config is {dag_run.conf}") # prints None if dag is run on scheduler

with DAG(
...
schedule_interval="* * * * *",
params={
"test_param":"test",
},) as dag

config_task = PythonOperator(task_id="parse_config", python_callable=parse_conf)
...
start_task.set_downstream(config_task)

Если даг запускается вручную, конфигурация соответствует желанию.
В файле конфигурации для параметра dag_run_conf_overrides_params установлено значение True< /п>

Подробнее здесь: https://stackoverflow.com/questions/785 ... parameters