'Extend volume.'

@utils.trace_method
def extend_volume(self, volume, size_gb):

    LOG.debug('Extend    volume')
    try:
        message_body = {}
        message_body['volume_guid'] = util.get_guid_with_curly_brackets(volume['id'])
        message_body['new_size'] = size_gb
        util.message_data_plane(self.dn_routing_key, 'hyperscale.storage.dm.volume.extend', **message_body)
    except (exception.UnableToProcessHyperScaleCmdOutput, exception.ErrorInSendingMsg):
        msg = (_('Exception    in    extend    volume    %s') % volume['name'])
        LOG.exception(msg)
        raise exception.VolumeDriverException(message=msg)
