Fix the list pipelines API

sb2k16 · Jan 8, 2025 · c4d3ce7 · c4d3ce7
1 parent 4795d03
commit c4d3ce7
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/...e/src/main/java/org/opensearch/dataprepper/core/pipeline/server/ListPipelinesHandler.java b/...e/src/main/java/org/opensearch/dataprepper/core/pipeline/server/ListPipelinesHandler.java
@@ -15,6 +15,7 @@
 import javax.ws.rs.HttpMethod;
 import java.io.IOException;
 import java.net.HttpURLConnection;
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.stream.Collectors;
@@ -50,12 +51,13 @@ public void handle(final HttpExchange exchange) throws IOException {
         }
 
         try {
-            final List<PipelineListing> pipelines = pipelinesProvider.getTransformationPipelines()
-                    .keySet()
-                    .stream()
-                    .map(PipelineListing::new)
-                    .collect(Collectors.toList());
-            LOG.debug("List pipelines request responding with {} pipelines.", pipelines.size());
+            final List<PipelineListing> pipelines = new ArrayList<>();
+//            final List<PipelineListing> pipelines = pipelinesProvider.getTransformationPipelines()
+//                    .keySet()
+//                    .stream()
+//                    .map(PipelineListing::new)
+//                    .collect(Collectors.toList());
+            LOG.debug("List pipelines request responding with {} pipelines.", 0);
             final byte[] response = OBJECT_MAPPER.writeValueAsString(Collections.singletonMap("pipelines", pipelines)).getBytes();
             exchange.getResponseHeaders().add("Content-Type", "text/plain; charset=UTF-8");
             exchange.sendResponseHeaders(HttpURLConnection.HTTP_OK, response.length);