Skip to content

Commit d20b021

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent 78e8059 commit d20b021

File tree

2 files changed

+13
-11
lines changed

2 files changed

+13
-11
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/SystemIndexMetadataUpgradeService.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,11 @@ public class SystemIndexMetadataUpgradeService implements ClusterStateListener {
5353
public SystemIndexMetadataUpgradeService(SystemIndices systemIndices, ClusterService clusterService) {
5454
this.systemIndices = systemIndices;
5555
this.clusterService = clusterService;
56-
this.taskQueue = clusterService.createTaskQueue("system-indices-metadata-upgrade", Priority.NORMAL,
57-
new SystemIndexMetadataUpgradeExecutor());
56+
this.taskQueue = clusterService.createTaskQueue(
57+
"system-indices-metadata-upgrade",
58+
Priority.NORMAL,
59+
new SystemIndexMetadataUpgradeExecutor()
60+
);
5861
}
5962

6063
@Override
@@ -173,8 +176,9 @@ static boolean hasVisibleAlias(IndexMetadata indexMetadata) {
173176
return indexMetadata.getAliases().values().stream().anyMatch(a -> Boolean.FALSE.equals(a.isHidden()));
174177
}
175178

176-
private record SystemIndexMetadataUpgradeTask(Collection<Index> changedIndices,
177-
Collection<DataStream> changedDataStreams) implements ClusterStateTaskListener {
179+
private record SystemIndexMetadataUpgradeTask(Collection<Index> changedIndices, Collection<DataStream> changedDataStreams)
180+
implements
181+
ClusterStateTaskListener {
178182

179183
@Override
180184
public void onFailure(Exception e) {

server/src/test/java/org/elasticsearch/cluster/metadata/SystemIndexMetadataUpgradeServiceTests.java

Lines changed: 5 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -84,16 +84,14 @@ public void setUpTest() {
8484
// set up a system index upgrade service
8585
ClusterService clusterService = mock(ClusterService.class);
8686
MasterServiceTaskQueue<ClusterStateTaskListener> queue = mock(MasterServiceTaskQueue.class);
87-
when(clusterService.createTaskQueue(eq("system-indices-metadata-upgrade"), eq(Priority.NORMAL), any()))
88-
.thenAnswer(invocation -> {
89-
executor = invocation.getArgument(2, ClusterStateTaskExecutor.class);
90-
return queue;
91-
});
87+
when(clusterService.createTaskQueue(eq("system-indices-metadata-upgrade"), eq(Priority.NORMAL), any())).thenAnswer(invocation -> {
88+
executor = invocation.getArgument(2, ClusterStateTaskExecutor.class);
89+
return queue;
90+
});
9291
doAnswer(invocation -> {
9392
task = invocation.getArgument(1, ClusterStateTaskListener.class);
9493
return null;
95-
}).when(queue)
96-
.submitTask(any(), any(), any());
94+
}).when(queue).submitTask(any(), any(), any());
9795

9896
this.service = new SystemIndexMetadataUpgradeService(
9997
new SystemIndices(

0 commit comments

Comments
 (0)