'Completion of the failover locally or via RPC.'

def finish_failover(self, context, service, updates):

    if service.is_clustered:
        for (key, value) in updates.items():
            setattr(service.cluster, key, value)
        service.cluster.save()
        rpcapi = volume_rpcapi.VolumeAPI()
        rpcapi.failover_completed(context, service, updates)
    else:
        service.update(updates)
        service.save()
