My initial thought is that doesn't quite sound like a whole operator, but a useful function to add to the EmrHook.
Could you describe in a little bit more detail how you use it? -a > On 13 Nov 2019, at 15:40, Aviem Zur <aviem...@gmail.com> wrote: > > Hi, > > I've created a new operator and want to check viability to contribute it to > airflow/contrib > > The operator is called: emr_cluster_name_to_id > > Given an EMR cluster name will return id of the first live cluster found > with a matching name. > This is useful for users with persistent EMR clusters they wish to add > steps to via airflow. > If the cluster dies and is replaced by a new cluster with the same name no > code or configuration needs to be changed since the operator will pick up > the correct id when the DAG is run. > > Is this a viable operator for airflow/contrib? > If so I'll create a JIRA task and a PR on GitHub. > > Thanks, > Aviem
