Skip to content

Commit 18e83bb

Browse files
committed
Correctly assert against ALREADY_EXISTS index
Signed-off-by: Andre Kurait <[email protected]>
1 parent 769b107 commit 18e83bb

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

MetadataMigration/src/test/java/org/opensearch/migrations/EndToEndTest.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -208,7 +208,8 @@ private void verifyCommandResults(
208208
var migratedItems = result.getItems();
209209
assertThat(getNames(getSuccessfulResults(migratedItems.getIndexTemplates())), containsInAnyOrder(testData.indexTemplateName));
210210
assertThat(getNames(getSuccessfulResults(migratedItems.getComponentTemplates())), equalTo(templateType.equals(TemplateType.IndexAndComponent) ? List.of(testData.compoTemplateName) : List.of()));
211-
assertThat(getNames(getSuccessfulResults(migratedItems.getIndexes())), containsInAnyOrder(testData.blogIndexName, testData.movieIndexName, testData.indexThatAlreadyExists));
211+
assertThat(getNames(getSuccessfulResults(migratedItems.getIndexes())), containsInAnyOrder(testData.blogIndexName, testData.movieIndexName));
212+
assertThat(getNames(getFailedResultsByType(migratedItems.getIndexes(), CreationResult.CreationFailureType.ALREADY_EXISTS)), containsInAnyOrder(testData.indexThatAlreadyExists));
212213
assertThat(getNames(getSuccessfulResults(migratedItems.getAliases())), containsInAnyOrder(testData.aliasInTemplate, testData.aliasName));
213214

214215
}
@@ -219,6 +220,12 @@ private List<CreationResult> getSuccessfulResults(List<CreationResult> results)
219220
.collect(Collectors.toList());
220221
}
221222

223+
private List<CreationResult> getFailedResultsByType(List<CreationResult> results, CreationResult.CreationFailureType failureType) {
224+
return results.stream()
225+
.filter(r -> failureType.equals(r.getFailureType()))
226+
.collect(Collectors.toList());
227+
}
228+
222229
private List<String> getNames(List<CreationResult> items) {
223230
return items.stream().map(r -> r.getName()).collect(Collectors.toList());
224231
}

0 commit comments

Comments
 (0)