'Complete failover on all services of the cluster.'

def failover_completed(self, ctxt, service, updates):

    cctxt = self._get_cctxt(service.service_topic_queue, '3.8', fanout=True)
    cctxt.cast(ctxt, 'failover_completed', updates=updates)
