Блог

есть ли какой-либо способ передать конфигурацию JSON из ручного запуска DAG (из dag_run.conf['attribute'] в KubernetesPodOperator?

Попытался использовать шаблон Jinja в поле шаблона в YAML, но получил ошибку, dag_run is not defined .

 task_parse_raw_data = KubernetesPodOperator(
        namespace=NAMESPACE, 
        image='artifactory/image:tag',
        service_account_name='airflow',
        cmds=["sh", "/current.sh"],
        arguments=[ {{ dag_run.conf['date']}} ],
        ...)
 

Вам нужно заключить выражение Jinja в кавычки, например так:

 arguments=[ "{{ dag_run.conf['date'] }}" ]