git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Configuration passing through airflow cli (trigger_dag)


Hi,
I need to pass certain arguments to my custom operator at run time. It seems that airflow cli's trigger_dag
command support passing conf at run time which referred in operator's execute function through {{ dag_run.conf['name'] }} template.
But I am not being able to read the "name" conf inside operator.
Am I missing something here. 
Any pointer on this would help me in moving forward.

Thanks,
Raman Gupta



( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-airflow-development/msg03248.html on line 78
Call Stack
#TimeMemoryFunctionLocation
10.0006362648{main}( ).../msg03248.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-airflow-development/msg03248.html on line 78
Call Stack
#TimeMemoryFunctionLocation
10.0006362648{main}( ).../msg03248.html:0