'Try to demote volumes on the current primary cluster.'

def _demote_volumes(self, volumes, until_failure=True):

    result = []
    try_demoting = True
    for volume in volumes:
        demoted = False
        if (try_demoting and self._is_replicated_type(volume.volume_type)):
            vol_name = utils.convert_str(volume.name)
            try:
                self._exec_on_volume(vol_name, self._active_config, 'mirror_image_demote')
                demoted = True
            except Exception as e:
                LOG.debug('Failed    to    demote    %(volume)s    with    error:    %(error)s.', {'volume': volume.name, 'error': e})
                try_demoting = (not until_failure)
        result.append(demoted)
    return result
