def METHOD_NAME(self, task_vars, context):
    res = self._wrap_call(set_cluster_multi_state, context["cluster_id"], self._task.args["state"])
    res["state"] = self._task.args["state"]
    return res