From 4ec45f5460eefb8a6bc06c099231becc7fb6fbdf Mon Sep 17 00:00:00 2001 From: davidko Date: Tue, 2 Jan 2024 11:10:46 +0800 Subject: [PATCH] test: fix engine/replica identity error check Signed-off-by: davidko --- integration/core/test_identity.py | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/integration/core/test_identity.py b/integration/core/test_identity.py index 555e574c9..408a5cd42 100644 --- a/integration/core/test_identity.py +++ b/integration/core/test_identity.py @@ -101,11 +101,10 @@ def test_validation_fails_with_client(engine_manager_client, ENGINE_NAME) get_controller_version_detail(e_client) # Retries until open socket. with pytest.raises(grpc.RpcError) as e: - e_client.replica_create('tcp://' + - get_process_address(replica_different)) - assert e.value.code() == grpc.StatusCode.UNKNOWN - assert (f'incorrect volume name {VOLUME_NAME}; check replica address') \ - in e.value.details() + e_client.replica_create('tcp://' + get_process_address(replica_different)) + + assert e.value.code() == grpc.StatusCode.FAILED_PRECONDITION + assert f'incorrect volume name {VOLUME_NAME}; check replica address' in e.value.details() # CASE 8: # Our sync agent client is right, so we can send it instructions, but it @@ -117,10 +116,12 @@ def test_validation_fails_with_client(engine_manager_client, sync_file_info_tuples = [("some_name", "some_name", 512)] with pytest.raises(grpc.RpcError) as e: s_client.sync_files(get_process_address(replica_different), - sync_file_info_tuples, True, 0) - assert e.value.code() == grpc.StatusCode.UNKNOWN - assert (f'incorrect volume name {VOLUME_NAME}; check replica address') \ - in e.value.details() + sync_file_info_tuples, + True, + 0) + + assert e.value.code() == grpc.StatusCode.FAILED_PRECONDITION + assert f'incorrect volume name {VOLUME_NAME}; check replica address' in e.value.details() def test_validation_fails_with_cli(bin, engine_manager_client, # NOQA process_manager_client):