airflow-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vincent Poulain <vincent.poul...@tinyclues.com>
Subject EMROperator templating
Date Tue, 20 Jun 2017 08:58:24 GMT
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 | vincent@tinyclues.com <support@tinyclues.com>

Tinyclues | 51 rue √Čtienne Marcel, 75001 Paris

www.tinyclues.com <http://bit.ly/2hNL4Fs> | @tinyclues
<https://twitter.com/Tinyclues>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message