| 
15 | 15 | import org.elasticsearch.action.admin.cluster.repositories.put.PutRepositoryRequest;  | 
16 | 16 | import org.elasticsearch.action.admin.cluster.repositories.put.TransportPutRepositoryAction;  | 
17 | 17 | import org.elasticsearch.action.admin.cluster.repositories.reservedstate.ReservedRepositoryAction;  | 
 | 18 | +import org.elasticsearch.action.admin.cluster.state.ClusterStateRequest;  | 
18 | 19 | import org.elasticsearch.client.internal.Client;  | 
19 | 20 | import org.elasticsearch.cluster.ClusterChangedEvent;  | 
20 | 21 | import org.elasticsearch.cluster.ClusterStateListener;  | 
 | 22 | +import org.elasticsearch.cluster.metadata.RepositoryMetadata;  | 
21 | 23 | import org.elasticsearch.cluster.metadata.ReservedStateErrorMetadata;  | 
22 | 24 | import org.elasticsearch.cluster.metadata.ReservedStateHandlerMetadata;  | 
23 | 25 | import org.elasticsearch.cluster.metadata.ReservedStateMetadata;  | 
@@ -129,13 +131,15 @@ private void assertClusterStateSaveOK(CountDownLatch savedClusterState, AtomicLo  | 
129 | 131 |         boolean awaitSuccessful = savedClusterState.await(20, TimeUnit.SECONDS);  | 
130 | 132 |         assertTrue(awaitSuccessful);  | 
131 | 133 | 
 
  | 
 | 134 | +        clusterAdmin().state(new ClusterStateRequest(TEST_REQUEST_TIMEOUT).waitForMetadataVersion(metadataVersion.get())).get();  | 
 | 135 | + | 
132 | 136 |         final var reposResponse = client().execute(  | 
133 | 137 |             GetRepositoriesAction.INSTANCE,  | 
134 | 138 |             new GetRepositoriesRequest(TEST_REQUEST_TIMEOUT, new String[] { "repo", "repo1" })  | 
135 | 139 |         ).get();  | 
136 | 140 | 
 
  | 
137 | 141 |         assertThat(  | 
138 |  | -            reposResponse.repositories().stream().map(r -> r.name()).collect(Collectors.toSet()),  | 
 | 142 | +            reposResponse.repositories().stream().map(RepositoryMetadata::name).collect(Collectors.toSet()),  | 
139 | 143 |             containsInAnyOrder("repo", "repo1")  | 
140 | 144 |         );  | 
141 | 145 | 
 
  | 
 | 
0 commit comments