Skip to content

Commit bd43116

Browse files
Merge branch 'ml-ccm-api-settings' of github.com:jonathan-buttner/elasticsearch into ml-ccm-api-settings
2 parents 6a095d2 + 8aca277 commit bd43116

File tree

2 files changed

+11
-11
lines changed
  • x-pack/plugin/inference/src
    • internalClusterTest/java/org/elasticsearch/xpack/inference/integration
    • main/java/org/elasticsearch/xpack/inference/services/elastic/ccm

2 files changed

+11
-11
lines changed

x-pack/plugin/inference/src/internalClusterTest/java/org/elasticsearch/xpack/inference/integration/BaseCCMIT.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,9 @@ public abstract class BaseCCMIT extends ESSingleNodeTestCase {
3737

3838
public interface Provider {
3939
void store(CCMModel ccmModel, ActionListener<Void> listener);
40+
4041
void get(ActionListener<CCMModel> listener);
42+
4143
void delete(ActionListener<Void> listener);
4244
}
4345

@@ -77,7 +79,8 @@ public void testStore_OverwritesConfiguration_WhenItAlreadyExists() {
7779

7880
var results = client().prepareSearch(CCMIndex.INDEX_PATTERN)
7981
.setQuery(QueryBuilders.idsQuery().addIds(CCM_DOC_ID))
80-
.execute().actionGet(TimeValue.THIRTY_SECONDS);
82+
.execute()
83+
.actionGet(TimeValue.THIRTY_SECONDS);
8184

8285
assertThat(results.getHits().getHits().length, is(1));
8386
}

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/services/elastic/ccm/CCMService.java

Lines changed: 7 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -24,17 +24,14 @@ public CCMService(CCMPersistentStorageService ccmPersistentStorageService) {
2424

2525
public void isEnabled(ActionListener<Boolean> listener) {
2626
// TODO use cache or cluster state to determine if CCM is enabled
27-
var ccmModelListener = ActionListener.<CCMModel>wrap(
28-
ignored -> listener.onResponse(true),
29-
e -> {
30-
if (e instanceof ResourceNotFoundException) {
31-
listener.onResponse(false);
32-
return;
33-
}
34-
35-
listener.onFailure(e);
27+
var ccmModelListener = ActionListener.<CCMModel>wrap(ignored -> listener.onResponse(true), e -> {
28+
if (e instanceof ResourceNotFoundException) {
29+
listener.onResponse(false);
30+
return;
3631
}
37-
);
32+
33+
listener.onFailure(e);
34+
});
3835

3936
ccmPersistentStorageService.get(ccmModelListener);
4037
}

0 commit comments

Comments
 (0)