@cpo.event_wrapper(
    True, step=_("Decommission %s") % "NodeManagers", param=('cluster', 0))
def _check_nodemanagers_decommission(cluster, instances):
    _check_decommission(cluster, instances, pu.get_nodemanagers_status,
                        c_helper.NODEMANAGERS_DECOMMISSIONING_TIMEOUT)
dataset/ETHPy150Open openstack/sahara/sahara/plugins/vanilla/hadoop2/scaling.py/_check_nodemanagers_decommission/original