We have an EMR connection type, but the operator actually uses this as a config 
value, and the actual credentials come form the default aws_conn_id:

    def __init__(
            self,
            aws_conn_id='s3_default',
            emr_conn_id='emr_default',
            job_flow_overrides=None,
            region_name=None,
            *args, **kwargs):

Oh also: that _should_ not say 's3_default' anymore :D

I would like to propose then that we remove the emr_default conneciton, and any 
reference to a connection in the EMR* Operators, and instead change the EMR 
config to come from a Variables instead.

-ash

Reply via email to