Hello,
I would like to use EmrCreateJobFlowOperator, using job_flow_overrides
attribute with dynamic attribute.
Example
EmrCreateJobFlowOperator(job_flow_overrides ={'foo' : '{{ xcom.pull }}'})
job_flow_overrides seems very nested to use jinja templating and
template_fields
is set to [].
Any idea to fetch data from xcom and using it in job_flow_overrides params
?
Thank
--
*Vincent Poulain*
Senior Software Engineer
Office +33 1 75 50 67 26 <+33%201%2075%2050%2067%2026> | Mobile +33 6 21 82
87 62 | [email protected] <[email protected]>
Tinyclues | 51 rue Étienne Marcel, 75001 Paris
www.tinyclues.com <http://bit.ly/2hNL4Fs> | @tinyclues
<https://twitter.com/Tinyclues>
