diff --git a/integration-tests/src/test_loop/tests/resharding_v3.rs b/integration-tests/src/test_loop/tests/resharding_v3.rs index 2b94aab58c8..ae652eceb13 100644 --- a/integration-tests/src/test_loop/tests/resharding_v3.rs +++ b/integration-tests/src/test_loop/tests/resharding_v3.rs @@ -514,11 +514,13 @@ fn test_resharding_v3_base(params: TestReshardingParameters) { print_and_assert_shard_accounts(&clients, &tip); } - check_state_shard_uid_mapping_after_resharding( - &client, - parent_shard_uid, - params.allow_negative_refcount, - ); + for client in clients.iter() { + check_state_shard_uid_mapping_after_resharding( + client, + parent_shard_uid, + params.allow_negative_refcount, + ); + } // Return false if garbage collection window has not passed yet since resharding. if epoch_height <= new_layout_epoch_height.get().unwrap() + GC_NUM_EPOCHS_TO_KEEP { @@ -557,6 +559,37 @@ fn shard_sequence_to_schedule(mut shard_sequence: Vec) -> Vec