def METHOD_NAME(
    self, node_type, node_id, restart_count=-1, error_data="", level=""
):
    """Process the training failure reported by the node."""
    node = self._job_nodes[node_type][node_id]
    self._error_monitor.process_error(
        node, restart_count, error_data, level
    )