def METHOD_NAME(nodes):
    """Validate disks used by ceph cluster
    Args:
        nodes (Ceph): list of Ceph objects
    """
    for node in nodes:
        try:
            _disks, _ = get_disk_list(sudo=True, node=node, expr="ceph-")
            raise CephadmOpsExecutionError(
                f"Failed to clean ceph disks on node '{node.ip_address} -\n{_disks}'"
            )
        except CommandFailed:
            log.info(f"Ceph disks are cleaned as expected on node '{node.ip_address}'")