Fixing ingest pipeline integ test (opensearch-project#614)

Signed-off-by: Joshua Palis <[email protected]>
joshpalis · Apr 1, 2024 · 06654b4 · 06654b4
1 parent 4de0d99
commit 06654b4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/test/java/org/opensearch/flowframework/FlowFrameworkRestTestCase.java b/src/test/java/org/opensearch/flowframework/FlowFrameworkRestTestCase.java
@@ -685,11 +685,11 @@ protected Response deleteUser(String user) throws IOException {
         );
     }
 
-    protected GetPipelineResponse getPipelines() throws IOException {
+    protected GetPipelineResponse getPipelines(String pipelineId) throws IOException {
         Response getPipelinesResponse = TestHelpers.makeRequest(
             client(),
             "GET",
-            "_ingest/pipeline",
+            "_ingest/pipeline/" + pipelineId,
             null,
             "",
             ImmutableList.of(new BasicHeader(HttpHeaders.USER_AGENT, ""))

diff --git a/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkRestApiIT.java b/src/test/java/org/opensearch/flowframework/rest/FlowFrameworkRestApiIT.java
@@ -393,7 +393,7 @@ public void testCreateAndProvisionIngestAndSearchPipeline() throws Exception {
         assertEquals(5, resourcesCreated.size());
         String modelId = resourcesCreated.get(2).resourceId();
 
-        GetPipelineResponse getPipelinesResponse = getPipelines();
+        GetPipelineResponse getPipelinesResponse = getPipelines("append-1");
 
         assertTrue(getPipelinesResponse.pipelines().get(0).toString().contains(modelId));