with session.begin():
volume_ref.save(session=session)
- meta = volume_metadata_get(context, volume_ref.id)
- volume_ref.metadata = meta
-
- result = model_query(context, models.Volume, read_deleted="no").\
- options(joinedload('volume_metadata')).\
- filter_by(id=volume_ref['id']).first()
- if not result:
- raise exception.VolumeNotFound(volume_id=volume_ref['id'])
-
- return result
+ return volume_get(context, values['id'], session=session)
@require_admin_context
return 1
@staticmethod
- def _create_volume(size='0', snapshot_id=None, image_id=None,
+ def _create_volume(size=0, snapshot_id=None, image_id=None,
metadata=None):
- #def _create_volume(size=0, snapshot_id=None):
"""Create a volume object."""
vol = {}
vol['size'] = size
def test_create_delete_volume_with_metadata(self):
"""Test volume can be created with metadata and deleted."""
test_meta = {'fake_key': 'fake_value'}
- volume = self._create_volume('0', None, metadata=test_meta)
+ volume = self._create_volume(0, None, metadata=test_meta)
volume_id = volume['id']
self.volume.create_volume(self.context, volume_id)
result_meta = {
# volume_create
return True
try:
- volume = self._create_volume('1001')
+ volume = self._create_volume(1001)
self.volume.create_volume(self.context, volume)
self.fail("Should have thrown TypeError")
except TypeError: