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