Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/tests/test_retry.py
Show All 26 Lines | def test_retrying_proxy_storage_content_add(swh_storage, sample_data): | ||||
content = next(swh_storage.content_get([sample_content['sha1']])) | content = next(swh_storage.content_get([sample_content['sha1']])) | ||||
assert not content | assert not content | ||||
s = swh_storage.content_add([sample_content]) | s = swh_storage.content_add([sample_content]) | ||||
assert s == { | assert s == { | ||||
'content:add': 1, | 'content:add': 1, | ||||
'content:add:bytes': sample_content['length'], | 'content:add:bytes': sample_content['length'], | ||||
'skipped_content:add': 0 | |||||
} | } | ||||
content = next(swh_storage.content_get([sample_content['sha1']])) | content = next(swh_storage.content_get([sample_content['sha1']])) | ||||
assert content['sha1'] == sample_content['sha1'] | assert content['sha1'] == sample_content['sha1'] | ||||
def test_retrying_proxy_storage_content_add_with_retry( | def test_retrying_proxy_storage_content_add_with_retry( | ||||
swh_storage, sample_data, mocker): | swh_storage, sample_data, mocker): | ||||
▲ Show 20 Lines • Show All 54 Lines • ▼ Show 20 Lines | def test_retrying_proxy_storage_content_add_metadata(swh_storage, sample_data): | ||||
pk = sample_content['sha1'] | pk = sample_content['sha1'] | ||||
content_metadata = swh_storage.content_get_metadata([pk]) | content_metadata = swh_storage.content_get_metadata([pk]) | ||||
assert not content_metadata[pk] | assert not content_metadata[pk] | ||||
s = swh_storage.content_add_metadata([sample_content]) | s = swh_storage.content_add_metadata([sample_content]) | ||||
assert s == { | assert s == { | ||||
'content:add': 1, | 'content:add': 1, | ||||
'skipped_content:add': 0 | |||||
} | } | ||||
content_metadata = swh_storage.content_get_metadata([pk]) | content_metadata = swh_storage.content_get_metadata([pk]) | ||||
assert len(content_metadata[pk]) == 1 | assert len(content_metadata[pk]) == 1 | ||||
assert content_metadata[pk][0]['sha1'] == pk | assert content_metadata[pk][0]['sha1'] == pk | ||||
def test_retrying_proxy_storage_content_add_metadata_with_retry( | def test_retrying_proxy_storage_content_add_metadata_with_retry( | ||||
▲ Show 20 Lines • Show All 785 Lines • Show Last 20 Lines |