def remove_from_compute(self, context, volume, instance_id, host):
    'Remove volume from specified compute host.'
    rpc.call(context, rpc.queue_get_for(context, FLAGS.compute_topic, host), {'method': 'remove_volume_connection', 'args': {'instance_id': instance_id, 'volume_id': volume['id']}})
Remove volume from specified compute host.
def remove_from_compute(self, context, volume, instance_id, host):
    
    rpc.call(context, rpc.queue_get_for(context, FLAGS.compute_topic, host), {'method': 'remove_volume_connection', 'args': {'instance_id': instance_id, 'volume_id': volume['id']}})