Spotless

carlosdelest · Mar 18, 2024 · 3b8db71 · 3b8db71
1 parent 88af861
commit 3b8db71
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/server/src/main/java/org/elasticsearch/action/bulk/BulkShardRequestInferenceProvider.java b/server/src/main/java/org/elasticsearch/action/bulk/BulkShardRequestInferenceProvider.java
@@ -76,10 +76,13 @@ public static void getInstance(
         Set<ShardId> shardIds,
         ActionListener<BulkShardRequestInferenceProvider> listener
     ) {
-        Set<String> inferenceIds =
-            shardIds.stream().map(ShardId::getIndex).collect(Collectors.toSet()).stream()
-                .map(index -> clusterState.metadata().index(index).getFieldInferenceMetadata().getFieldInferenceOptions().values())
-                .flatMap(o -> o.stream().map(FieldInferenceMetadata.FieldInferenceOptions::inferenceId)).collect(Collectors.toSet());
+        Set<String> inferenceIds = shardIds.stream()
+            .map(ShardId::getIndex)
+            .collect(Collectors.toSet())
+            .stream()
+            .map(index -> clusterState.metadata().index(index).getFieldInferenceMetadata().getFieldInferenceOptions().values())
+            .flatMap(o -> o.stream().map(FieldInferenceMetadata.FieldInferenceOptions::inferenceId))
+            .collect(Collectors.toSet());
         final Map<String, InferenceProvider> inferenceProviderMap = new ConcurrentHashMap<>();
         Runnable onModelLoadingComplete = () -> listener.onResponse(
             new BulkShardRequestInferenceProvider(clusterState, inferenceProviderMap)