Skip to content

Commit 249946f

Browse files
committed
[Test] Actually invoke the listener on failure case
The listener is expected to be called on failure case. This PR does that. Resolves: #131979
1 parent 321b106 commit 249946f

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

test/external-modules/multi-project/src/test/java/org/elasticsearch/multiproject/action/DeleteProjectActionTests.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -59,12 +59,12 @@ public void testDeleteNonExisting() throws Exception {
5959
var projects = randomList(1, 5, ESTestCase::randomUniqueProjectId);
6060
var deletedProjects = randomSubsetOf(projects);
6161
var state = buildState(projects);
62-
var listener = ActionListener.assertAtLeastOnce(
63-
ActionTestUtils.<AcknowledgedResponse>assertNoSuccessListener(e -> assertTrue(e instanceof IllegalArgumentException))
64-
);
62+
var listener = ActionListener.assertAtLeastOnce(ActionTestUtils.<AcknowledgedResponse>assertNoSuccessListener(e -> {
63+
assertTrue(e instanceof IllegalArgumentException);
64+
}));
6565
var nonExistingTask = createTask(randomUniqueProjectId(), listener);
6666
var tasks = Stream.concat(Stream.of(nonExistingTask), deletedProjects.stream().map(this::createTask)).toList();
67-
var result = ClusterStateTaskExecutorUtils.executeIgnoringFailures(state, executor, tasks);
67+
var result = ClusterStateTaskExecutorUtils.executeHandlingResults(state, executor, tasks, t -> {}, DeleteProjectTask::onFailure);
6868
for (ProjectId deletedProject : deletedProjects) {
6969
assertNull(result.metadata().projects().get(deletedProject));
7070
assertNull(result.globalRoutingTable().routingTables().get(deletedProject));

0 commit comments

Comments
 (0)