TrueCloudLab/s3-tests
7
0
Fork 1
mirror of https://github.com/ceph/s3-tests.git synced 2025-02-21 15:28:06 +00:00
Code Issues 2 Projects Releases Packages Wiki Activity

Tag versioning tests

Browse source
This commit is contained in:
Andrew Gaul 2024-09-03 15:49:21 +02:00
parent e8db6c2c16
commit 356152c12f
1 changed files with 28 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
s3tests_boto3/functional/test_s3.py
View file

@ -1413,6 +1413,7 @@ def test_bucket_list_return_data():
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_bucket_list_return_data_versioning(): def test_bucket_list_return_data_versioning():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
check_configure_versioning_retry(bucket_name, "Enabled", "Enabled") check_configure_versioning_retry(bucket_name, "Enabled", "Enabled")
@ -1639,6 +1640,7 @@ def _make_objs_dict(key_names):
objs_dict = {'Objects': objs_list} objs_dict = {'Objects': objs_list}
return objs_dict return objs_dict
@pytest.mark.versioning
def test_versioning_concurrent_multi_object_delete(): def test_versioning_concurrent_multi_object_delete():
num_objects = 5 num_objects = 5
num_threads = 5 num_threads = 5
@ -5603,6 +5605,7 @@ def test_object_copy_key_not_found():
assert status == 404 assert status == 404
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_object_copy_versioned_bucket(): def test_object_copy_versioned_bucket():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -5667,6 +5670,7 @@ def test_object_copy_versioned_bucket():
assert size == response['ContentLength'] assert size == response['ContentLength']
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_object_copy_versioned_url_encoding(): def test_object_copy_versioned_url_encoding():
bucket = get_new_bucket_resource() bucket = get_new_bucket_resource()
check_configure_versioning_retry(bucket.name, "Enabled", "Enabled") check_configure_versioning_retry(bucket.name, "Enabled", "Enabled")
@ -5730,6 +5734,7 @@ def _multipart_upload(bucket_name, key, size, part_size=5*1024*1024, client=None
return (upload_id, s, parts) return (upload_id, s, parts)
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_object_copy_versioning_multipart_upload(): def test_object_copy_versioning_multipart_upload():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -6078,6 +6083,7 @@ def check_configure_versioning_retry(bucket_name, status, expected_string):
assert expected_string == read_status assert expected_string == read_status
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_multipart_copy_versioned(): def test_multipart_copy_versioned():
src_bucket_name = get_new_bucket() src_bucket_name = get_new_bucket()
dest_bucket_name = get_new_bucket() dest_bucket_name = get_new_bucket()
@ -7321,6 +7327,7 @@ def test_ranged_request_empty_object():
assert status == 416 assert status == 416
assert error_code == 'InvalidRange' assert error_code == 'InvalidRange'
@pytest.mark.versioning
def test_versioning_bucket_create_suspend(): def test_versioning_bucket_create_suspend():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
check_versioning(bucket_name, None) check_versioning(bucket_name, None)
@ -7404,6 +7411,7 @@ def _do_test_create_remove_versions(client, bucket_name, key, num_versions, remo
print(response['Versions']) print(response['Versions'])
@pytest.mark.versioning
def test_versioning_obj_create_read_remove(): def test_versioning_obj_create_read_remove():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7418,6 +7426,7 @@ def test_versioning_obj_create_read_remove():
_do_test_create_remove_versions(client, bucket_name, key, num_versions, 4, -1) _do_test_create_remove_versions(client, bucket_name, key, num_versions, 4, -1)
_do_test_create_remove_versions(client, bucket_name, key, num_versions, 3, 3) _do_test_create_remove_versions(client, bucket_name, key, num_versions, 3, 3)
@pytest.mark.versioning
def test_versioning_obj_create_read_remove_head(): def test_versioning_obj_create_read_remove_head():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
@ -7452,6 +7461,7 @@ def test_versioning_obj_create_read_remove_head():
clean_up_bucket(client, bucket_name, key, version_ids) clean_up_bucket(client, bucket_name, key, version_ids)
@pytest.mark.versioning
def test_versioning_obj_plain_null_version_removal(): def test_versioning_obj_plain_null_version_removal():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
check_versioning(bucket_name, None) check_versioning(bucket_name, None)
@ -7472,6 +7482,7 @@ def test_versioning_obj_plain_null_version_removal():
response = client.list_object_versions(Bucket=bucket_name) response = client.list_object_versions(Bucket=bucket_name)
assert not 'Versions' in response assert not 'Versions' in response
@pytest.mark.versioning
def test_versioning_obj_plain_null_version_overwrite(): def test_versioning_obj_plain_null_version_overwrite():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
check_versioning(bucket_name, None) check_versioning(bucket_name, None)
@ -7505,6 +7516,7 @@ def test_versioning_obj_plain_null_version_overwrite():
response = client.list_object_versions(Bucket=bucket_name) response = client.list_object_versions(Bucket=bucket_name)
assert not 'Versions' in response assert not 'Versions' in response
@pytest.mark.versioning
def test_versioning_obj_plain_null_version_overwrite_suspended(): def test_versioning_obj_plain_null_version_overwrite_suspended():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
check_versioning(bucket_name, None) check_versioning(bucket_name, None)
@ -7570,6 +7582,7 @@ def overwrite_suspended_versioning_obj(client, bucket_name, key, version_ids, co
return (version_ids, contents) return (version_ids, contents)
@pytest.mark.versioning
def test_versioning_obj_suspend_versions(): def test_versioning_obj_suspend_versions():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7603,6 +7616,7 @@ def test_versioning_obj_suspend_versions():
assert len(version_ids) == len(contents) assert len(version_ids) == len(contents)
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_versioning_obj_suspended_copy(): def test_versioning_obj_suspended_copy():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7637,6 +7651,7 @@ def test_versioning_obj_suspended_copy():
clean_up_bucket(client, bucket_name, key1, version_ids) clean_up_bucket(client, bucket_name, key1, version_ids)
@pytest.mark.versioning
def test_versioning_obj_create_versions_remove_all(): def test_versioning_obj_create_versions_remove_all():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7653,6 +7668,7 @@ def test_versioning_obj_create_versions_remove_all():
assert len(version_ids) == 0 assert len(version_ids) == 0
assert len(version_ids) == len(contents) assert len(version_ids) == len(contents)
@pytest.mark.versioning
def test_versioning_obj_create_versions_remove_special_names(): def test_versioning_obj_create_versions_remove_special_names():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7671,6 +7687,7 @@ def test_versioning_obj_create_versions_remove_special_names():
assert len(version_ids) == len(contents) assert len(version_ids) == len(contents)
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_versioning_obj_create_overwrite_multipart(): def test_versioning_obj_create_overwrite_multipart():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7699,6 +7716,7 @@ def test_versioning_obj_create_overwrite_multipart():
assert len(version_ids) == 0 assert len(version_ids) == 0
assert len(version_ids) == len(contents) assert len(version_ids) == len(contents)
@pytest.mark.versioning
def test_versioning_obj_list_marker(): def test_versioning_obj_list_marker():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7755,6 +7773,7 @@ def test_versioning_obj_list_marker():
i += 1 i += 1
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_versioning_copy_obj_version(): def test_versioning_copy_obj_version():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7792,6 +7811,7 @@ def test_versioning_copy_obj_version():
body = _get_body(response) body = _get_body(response)
assert body == contents[-1] assert body == contents[-1]
@pytest.mark.versioning
def test_versioning_multi_object_delete(): def test_versioning_multi_object_delete():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7817,6 +7837,7 @@ def test_versioning_multi_object_delete():
response = client.list_object_versions(Bucket=bucket_name) response = client.list_object_versions(Bucket=bucket_name)
assert not 'Versions' in response assert not 'Versions' in response
@pytest.mark.versioning
def test_versioning_multi_object_delete_with_marker(): def test_versioning_multi_object_delete_with_marker():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7850,6 +7871,7 @@ def test_versioning_multi_object_delete_with_marker():
assert not 'DeleteMarkers' in response assert not 'DeleteMarkers' in response
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_versioning_multi_object_delete_with_marker_create(): def test_versioning_multi_object_delete_with_marker_create():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7871,6 +7893,7 @@ def test_versioning_multi_object_delete_with_marker_create():
assert delete_marker_version_id == delete_markers[0]['VersionId'] assert delete_marker_version_id == delete_markers[0]['VersionId']
assert key == delete_markers[0]['Key'] assert key == delete_markers[0]['Key']
@pytest.mark.versioning
def test_versioned_object_acl(): def test_versioned_object_acl():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -7939,6 +7962,7 @@ def test_versioned_object_acl():
check_grants(grants, default_policy) check_grants(grants, default_policy)
@pytest.mark.fails_on_dbstore @pytest.mark.fails_on_dbstore
@pytest.mark.versioning
def test_versioned_object_acl_no_version_specified(): def test_versioned_object_acl_no_version_specified():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -8027,6 +8051,7 @@ def _do_clear_versioned_bucket_concurrent(client, bucket_name):
# TODO: remove fails_on_rgw when https://tracker.ceph.com/issues/39142 is resolved # TODO: remove fails_on_rgw when https://tracker.ceph.com/issues/39142 is resolved
@pytest.mark.fails_on_rgw @pytest.mark.fails_on_rgw
@pytest.mark.versioning
def test_versioned_concurrent_object_create_concurrent_remove(): def test_versioned_concurrent_object_create_concurrent_remove():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -8051,6 +8076,7 @@ def test_versioned_concurrent_object_create_concurrent_remove():
response = client.list_object_versions(Bucket=bucket_name) response = client.list_object_versions(Bucket=bucket_name)
assert not 'Versions' in response assert not 'Versions' in response
@pytest.mark.versioning
def test_versioned_concurrent_object_create_and_remove(): def test_versioned_concurrent_object_create_and_remove():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -11154,6 +11180,7 @@ def test_delete_tags_obj_public():
response = client.get_object_tagging(Bucket=bucket_name, Key=key) response = client.get_object_tagging(Bucket=bucket_name, Key=key)
assert len(response['TagSet']) == 0 assert len(response['TagSet']) == 0
@pytest.mark.versioning
def test_versioning_bucket_atomic_upload_return_version_id(): def test_versioning_bucket_atomic_upload_return_version_id():
bucket_name = get_new_bucket() bucket_name = get_new_bucket()
client = get_client() client = get_client()
@ -11183,6 +11210,7 @@ def test_versioning_bucket_atomic_upload_return_version_id():
response = client.put_object(Bucket=bucket_name, Key=key) response = client.put_object(Bucket=bucket_name, Key=key)
assert not 'VersionId' in response assert not 'VersionId' in response
@pytest.mark.versioning
def test_versioning_bucket_multipart_upload_return_version_id(): def test_versioning_bucket_multipart_upload_return_version_id():
content_type='text/bla' content_type='text/bla'
objlen = 30 * 1024 * 1024 objlen = 30 * 1024 * 1024