Skip to content

Commit f6d88ac

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent 9bd4fbc commit f6d88ac

File tree

2 files changed

+5
-15
lines changed

2 files changed

+5
-15
lines changed

server/src/main/java/org/elasticsearch/ingest/IngestService.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -737,6 +737,7 @@ private record IngestPipelinesExecutionResult(
737737
String failedIndex,
738738
IndexDocFailureStoreStatus failureStoreStatus
739739
) {
740+
740741
private static final IngestPipelinesExecutionResult SUCCESSFUL_RESULT = new IngestPipelinesExecutionResult(
741742
true,
742743
true,
@@ -754,6 +755,7 @@ private record IngestPipelinesExecutionResult(
754755
private static IngestPipelinesExecutionResult failAndStoreFor(String index, Exception e) {
755756
return new IngestPipelinesExecutionResult(false, true, e, index, IndexDocFailureStoreStatus.USED);
756757
}
758+
757759
private static IngestPipelinesExecutionResult failWithoutStoringIn(String index, Exception e) {
758760
return new IngestPipelinesExecutionResult(false, true, e, index, IndexDocFailureStoreStatus.NOT_ENABLED);
759761
}

server/src/test/java/org/elasticsearch/ingest/IngestServiceTests.java

Lines changed: 3 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -1419,11 +1419,7 @@ public void testExecuteFailure() throws Exception {
14191419
EsExecutors.DIRECT_EXECUTOR_SERVICE
14201420
);
14211421
verify(processor).execute(eqIndexTypeId(indexRequest.version(), indexRequest.versionType(), Map.of()), any());
1422-
verify(failureHandler, times(1)).apply(
1423-
eq(0),
1424-
any(RuntimeException.class),
1425-
eq(fsStatus)
1426-
);
1422+
verify(failureHandler, times(1)).apply(eq(0), any(RuntimeException.class), eq(fsStatus));
14271423
verify(completionHandler, times(1)).accept(Thread.currentThread(), null);
14281424
}
14291425

@@ -1531,11 +1527,7 @@ public void testExecuteFailureWithNestedOnFailure() throws Exception {
15311527
EsExecutors.DIRECT_EXECUTOR_SERVICE
15321528
);
15331529
verify(processor).execute(eqIndexTypeId(indexRequest.version(), indexRequest.versionType(), Map.of()), any());
1534-
verify(failureHandler, times(1)).apply(
1535-
eq(0),
1536-
any(RuntimeException.class),
1537-
eq(fsStatus)
1538-
);
1530+
verify(failureHandler, times(1)).apply(eq(0), any(RuntimeException.class), eq(fsStatus));
15391531
verify(completionHandler, times(1)).accept(Thread.currentThread(), null);
15401532
}
15411533

@@ -1600,11 +1592,7 @@ public void testBulkRequestExecutionWithFailures() throws Exception {
16001592
EsExecutors.DIRECT_EXECUTOR_SERVICE
16011593
);
16021594

1603-
verify(requestItemErrorHandler, times(numIndexRequests)).apply(
1604-
anyInt(),
1605-
argThat(e -> e.getCause().equals(error)),
1606-
eq(fsStatus)
1607-
);
1595+
verify(requestItemErrorHandler, times(numIndexRequests)).apply(anyInt(), argThat(e -> e.getCause().equals(error)), eq(fsStatus));
16081596
verify(completionHandler, times(1)).accept(Thread.currentThread(), null);
16091597
}
16101598

0 commit comments

Comments
 (0)