'Perform this service/cluster resource cleanup as requested.'

@rpc.assert_min_rpc_version('3.7')
def do_cleanup(self, ctxt, cleanup_request):

    destination = cleanup_request.service_topic_queue
    cctxt = self._get_cctxt(destination, '3.7')
    cctxt.cast(ctxt, 'do_cleanup', cleanup_request=cleanup_request)
