:mod:`airflow.contrib.operators.emr_create_job_flow_operator`
=============================================================

.. py:module:: airflow.contrib.operators.emr_create_job_flow_operator


Module Contents
---------------

.. py:class:: EmrCreateJobFlowOperator(aws_conn_id='s3_default', emr_conn_id='emr_default', job_flow_overrides=None, region_name=None, *args, **kwargs)

   Bases: :class:`airflow.models.BaseOperator`

   Creates an EMR JobFlow, reading the config from the EMR connection.
   A dictionary of JobFlow overrides can be passed that override
   the config from the connection.

   :param aws_conn_id: aws connection to uses
   :type aws_conn_id: str
   :param emr_conn_id: emr connection to use
   :type emr_conn_id: str
   :param job_flow_overrides: boto3 style arguments to override
      emr_connection extra. (templated)
   :type job_flow_overrides: dict

   .. attribute:: template_fields
      :annotation: = ['job_flow_overrides']

      
   .. attribute:: template_ext
      :annotation: = []

      
   .. attribute:: ui_color
      :annotation: = #f9c915

      
   .. method:: execute(self, context)