def get_jobflow_id(emr_connection, name):
 ret = emr_connection.list_clusters(cluster_states=LIVE_STATES)
 clusters = ret.clusters
 try:
  return [cluster.id for cluster in clusters if (cluster.name == name)][0]
 except IndexError:
  return

def get_jobflow_id ( emr_connection , name ) : ret = emr_connection . list_clusters ( cluster_states = LIVE_STATES ) clusters = ret . clusters try : return [ cluster . id for cluster in clusters if ( cluster . name == name ) ] [ 0 ] except IndexError : return
return id of the live cluster with specified name .