Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/tests/test_retry.py
| Show First 20 Lines • Show All 256 Lines • ▼ Show 20 Lines | def test_retrying_proxy_swh_storage_origin_visit_add(swh_storage, sample_data): | ||||
| sample_origin = sample_data['origin'][0] | sample_origin = sample_data['origin'][0] | ||||
| swh_storage.origin_add_one(sample_origin) | swh_storage.origin_add_one(sample_origin) | ||||
| origin_url = sample_origin['url'] | origin_url = sample_origin['url'] | ||||
| origin = list(swh_storage.origin_visit_get(origin_url)) | origin = list(swh_storage.origin_visit_get(origin_url)) | ||||
| assert not origin | assert not origin | ||||
| origin = Origin(url=origin_url) | origin = Origin(url=origin_url) | ||||
| result = swh_storage.origin_visit_add( | origin_visit = swh_storage.origin_visit_add( | ||||
| origin, '2020-01-01', 'hg') | origin, '2020-01-01', 'hg') | ||||
| origin_visit = result['visit'] | |||||
| assert origin_visit.origin == origin_url | assert origin_visit.origin == origin_url | ||||
| assert isinstance(origin_visit.visit, int) | assert isinstance(origin_visit.visit, int) | ||||
| origin_visit = next(swh_storage.origin_visit_get(origin_url)) | origin_visit = next(swh_storage.origin_visit_get(origin_url)) | ||||
| assert origin_visit['origin'] == origin_url | assert origin_visit['origin'] == origin_url | ||||
| assert isinstance(origin_visit['visit'], int) | assert isinstance(origin_visit['visit'], int) | ||||
| ▲ Show 20 Lines • Show All 322 Lines • ▼ Show 20 Lines | def test_retrying_proxy_swh_storage_origin_visit_update( | ||||
| swh_storage, sample_data): | swh_storage, sample_data): | ||||
| """Standard origin_visit_update works as before | """Standard origin_visit_update works as before | ||||
| """ | """ | ||||
| sample_origin = sample_data['origin'][0] | sample_origin = sample_data['origin'][0] | ||||
| swh_storage.origin_add_one(sample_origin) | swh_storage.origin_add_one(sample_origin) | ||||
| origin_url = sample_origin['url'] | origin_url = sample_origin['url'] | ||||
| origin = Origin(url=origin_url) | origin = Origin(url=origin_url) | ||||
| result = swh_storage.origin_visit_add( | origin_visit = swh_storage.origin_visit_add( | ||||
| origin, '2020-01-01', 'hg') | origin, '2020-01-01', 'hg') | ||||
| origin_visit = result['visit'] | |||||
| ov = next(swh_storage.origin_visit_get(origin_url)) | ov = next(swh_storage.origin_visit_get(origin_url)) | ||||
| assert ov['origin'] == origin_url | assert ov['origin'] == origin_url | ||||
| assert ov['visit'] == origin_visit.visit | assert ov['visit'] == origin_visit.visit | ||||
| assert ov['status'] == 'ongoing' | assert ov['status'] == 'ongoing' | ||||
| assert ov['snapshot'] is None | assert ov['snapshot'] is None | ||||
| assert ov['metadata'] is None | assert ov['metadata'] is None | ||||
| ▲ Show 20 Lines • Show All 370 Lines • Show Last 20 Lines | |||||