Or we should remove the aws_conn_id from the Emr* (hook and op) rather than passing in two connection types.
Anyone have a though as to which way to go? > On 15 Apr 2019, at 11:51, Ash Berlin-Taylor <a...@apache.org> wrote: > > 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