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