spotless apply

Signed-off-by: Jackie Han <[email protected]>
jackiehanyang · Oct 2, 2023 · d1a2c14 · d1a2c14
1 parent 2ee84c8
commit d1a2c14
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 8 deletions.
diff --git a/src/main/java/org/opensearch/flowframework/exception/FlowFrameworkException.java b/src/main/java/org/opensearch/flowframework/exception/FlowFrameworkException.java
@@ -16,6 +16,7 @@
 public class FlowFrameworkException extends RuntimeException {
 
     private final Response.Status restStatus;
+
     /**
      * Constructor with error message.
      *

diff --git a/src/main/java/org/opensearch/flowframework/indices/FlowFrameworkIndex.java b/src/main/java/org/opensearch/flowframework/indices/FlowFrameworkIndex.java
@@ -20,9 +20,9 @@
  */
 public enum FlowFrameworkIndex {
     GLOBAL_CONTEXT(
-            GLOBAL_CONTEXT_INDEX,
-            ThrowingSupplierWrapper.throwingSupplierWrapper(GlobalContextHandler::getGlobalContextMappings),
-            GLOBAL_CONTEXT_INDEX_VERSION
+        GLOBAL_CONTEXT_INDEX,
+        ThrowingSupplierWrapper.throwingSupplierWrapper(GlobalContextHandler::getGlobalContextMappings),
+        GLOBAL_CONTEXT_INDEX_VERSION
     );
 
     private final String indexName;
@@ -46,4 +46,4 @@ public String getMapping() {
     public Integer getVersion() {
         return version;
     }
-}
+}
diff --git a/src/main/java/org/opensearch/flowframework/indices/GlobalContextHandler.java b/src/main/java/org/opensearch/flowframework/indices/GlobalContextHandler.java
@@ -26,6 +26,7 @@
 import org.opensearch.flowframework.workflow.CreateIndexStep;
 
 import javax.ws.rs.core.Response;
+
 import java.io.IOException;
 import java.util.HashMap;
 import java.util.Map;
@@ -73,7 +74,9 @@ private void initGlobalContextIndexIfAbsent(ActionListener<Boolean> listener) {
     public void putTemplateToGlobalContext(Template template, ActionListener<IndexResponse> listener) {
         initGlobalContextIndexIfAbsent(ActionListener.wrap(indexCreated -> {
             if (!indexCreated) {
-                listener.onFailure(new FlowFrameworkException("No response to create global_context index", Response.Status.INTERNAL_SERVER_ERROR));
+                listener.onFailure(
+                    new FlowFrameworkException("No response to create global_context index", Response.Status.INTERNAL_SERVER_ERROR)
+                );
                 return;
             }
             IndexRequest request = new IndexRequest(GLOBAL_CONTEXT_INDEX);

diff --git a/src/main/java/org/opensearch/flowframework/workflow/CreateIndexStep.java b/src/main/java/org/opensearch/flowframework/workflow/CreateIndexStep.java
@@ -29,6 +29,7 @@
 import org.opensearch.flowframework.indices.FlowFrameworkIndex;
 
 import javax.ws.rs.core.Response;
+
 import java.io.IOException;
 import java.net.URL;
 import java.util.HashMap;
@@ -165,15 +166,23 @@ public void initIndexIfAbsent(FlowFrameworkIndex index, ActionListener<Boolean>
                                                         internalListener.onResponse(true);
                                                     } else {
                                                         internalListener.onFailure(
-                                                            new FlowFrameworkException("Failed to update index setting for: " + indexName, Response.Status.INTERNAL_SERVER_ERROR)
+                                                            new FlowFrameworkException(
+                                                                "Failed to update index setting for: " + indexName,
+                                                                Response.Status.INTERNAL_SERVER_ERROR
+                                                            )
                                                         );
                                                     }
                                                 }, exception -> {
                                                     logger.error("Failed to update index setting for: " + indexName, exception);
                                                     internalListener.onFailure(exception);
                                                 }));
                                         } else {
-                                            internalListener.onFailure(new FlowFrameworkException("Failed to update index: " + indexName, Response.Status.INTERNAL_SERVER_ERROR));
+                                            internalListener.onFailure(
+                                                new FlowFrameworkException(
+                                                    "Failed to update index: " + indexName,
+                                                    Response.Status.INTERNAL_SERVER_ERROR
+                                                )
+                                            );
                                         }
                                     }, exception -> {
                                         logger.error("Failed to update index " + indexName, exception);

diff --git a/src/test/java/org/opensearch/flowframework/indices/GlobalContextHandlerTests.java b/src/test/java/org/opensearch/flowframework/indices/GlobalContextHandlerTests.java
@@ -24,7 +24,6 @@
 import org.opensearch.flowframework.workflow.CreateIndexStep;
 import org.opensearch.test.OpenSearchTestCase;
 import org.opensearch.threadpool.ThreadPool;
-import org.junit.Test;
 
 import java.io.IOException;
 import java.util.HashMap;
-Original file line number
+Diff line change
@@ Expand Up / @@ -16,6 +16,7 @@ @@
     public class FlowFrameworkException extends RuntimeException {
         private final Response.Status restStatus;
         /**
          * Constructor with error message.
          *
@@ Expand Down @@