@wrap_check_policy
def initialize_connection(self, context, volume, connector):
    host = volume['host']
    queue = rpc.queue_get_for(context, FLAGS.volume_topic, host)
    return rpc.call(context, queue, {'method': 'initialize_connection', 'args': {'volume_id': volume['id'], 'connector': connector}})
@wrap_check_policy
def initialize_connection(self, context, volume, connector):
    host = volume['host']
    queue = rpc.queue_get_for(context, FLAGS.volume_topic, host)
    return rpc.call(context, queue, {'method': 'initialize_connection', 'args': {'volume_id': volume['id'], 'connector': connector}})