diff --git a/src/test/java/org/opensearch/flowframework/FlowFrameworkRestTestCase.java b/src/test/java/org/opensearch/flowframework/FlowFrameworkRestTestCase.java
index 423d0ae8c..8cbabc95f 100644
--- 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
index d00bec2b4..67e21150b 100644
--- 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));