Skip to content

Commit 8aca277

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent 8f374e1 commit 8aca277

File tree

5 files changed

+21
-19
lines changed

5 files changed

+21
-19
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/internalClusterTest/java/org/elasticsearch/xpack/inference/integration/CCMPersistentStorageServiceIT.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -91,7 +91,8 @@ public void testStore_OverwritesConfiguration_WhenItAlreadyExists() {
9191

9292
var results = client().prepareSearch(CCMIndex.INDEX_PATTERN)
9393
.setQuery(QueryBuilders.idsQuery().addIds(CCM_DOC_ID))
94-
.execute().actionGet(TimeValue.THIRTY_SECONDS);
94+
.execute()
95+
.actionGet(TimeValue.THIRTY_SECONDS);
9596

9697
assertThat(results.getHits().getHits().length, is(1));
9798
}

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,8 @@ public void testStore_OverwritesConfiguration_WhenItAlreadyExists() {
7171

7272
var results = client().prepareSearch(CCMIndex.INDEX_PATTERN)
7373
.setQuery(QueryBuilders.idsQuery().addIds(CCM_DOC_ID))
74-
.execute().actionGet(TimeValue.THIRTY_SECONDS);
74+
.execute()
75+
.actionGet(TimeValue.THIRTY_SECONDS);
7576

7677
assertThat(results.getHits().getHits().length, is(1));
7778
}

x-pack/plugin/inference/src/main/java/org/elasticsearch/xpack/inference/action/TransportGetCCMConfigurationAction.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,11 +24,7 @@ public class TransportGetCCMConfigurationAction extends HandledTransportAction<
2424
private final CCMService ccmService;
2525

2626
@Inject
27-
public TransportGetCCMConfigurationAction(
28-
TransportService transportService,
29-
ActionFilters actionFilters,
30-
CCMService ccmService
31-
) {
27+
public TransportGetCCMConfigurationAction(TransportService transportService, ActionFilters actionFilters, CCMService ccmService) {
3228
super(
3329
GetCCMConfigurationAction.NAME,
3430
transportService,
@@ -40,7 +36,11 @@ public TransportGetCCMConfigurationAction(
4036
}
4137

4238
@Override
43-
protected void doExecute(Task task, GetCCMConfigurationAction.Request request, ActionListener<GetCCMConfigurationAction.Response> listener) {
39+
protected void doExecute(
40+
Task task,
41+
GetCCMConfigurationAction.Request request,
42+
ActionListener<GetCCMConfigurationAction.Response> listener
43+
) {
4444
var enabledListener = ActionListener.<Boolean>wrap(
4545
enabled -> listener.onResponse(new GetCCMConfigurationAction.Response(enabled)),
4646
listener::onFailure

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)