def _connect_volume(self, connection_info, disk_info):
    driver_type = connection_info.get('driver_volume_type')
    if (driver_type not in self.volume_drivers):
        raise exception.VolumeDriverNotFound(driver_type=driver_type)
    driver = self.volume_drivers[driver_type]
    return driver.connect_volume(connection_info, disk_info)
def _connect_volume(self, connection_info, disk_info):
    driver_type = connection_info.get('driver_volume_type')
    if (driver_type not in self.volume_drivers):
        raise exception.VolumeDriverNotFound(driver_type=driver_type)
    driver = self.volume_drivers[driver_type]
    return driver.connect_volume(connection_info, disk_info)