Skip to content

Commit 3eb5b68

Browse files
committed
Add more tests
1 parent 23bdac0 commit 3eb5b68

File tree

2 files changed

+173
-113
lines changed

2 files changed

+173
-113
lines changed

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/session/EsqlCCSUtils.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -380,8 +380,8 @@ public static <T> ActionListener<T> skipUnavailableListener(
380380
EsqlExecutionInfo.Cluster.Status status
381381
) {
382382
return delegate.delegateResponse((l, e) -> {
383-
if (EsqlCCSUtils.shouldIgnoreRuntimeError(executionInfo, clusterAlias, e)) {
384-
EsqlCCSUtils.markClusterWithFinalStateAndNoShards(executionInfo, clusterAlias, status, e);
383+
if (shouldIgnoreRuntimeError(executionInfo, clusterAlias, e)) {
384+
markClusterWithFinalStateAndNoShards(executionInfo, clusterAlias, status, e);
385385
l.onResponse(null);
386386
} else {
387387
l.onFailure(e);

0 commit comments

Comments
 (0)