fix pipeline create bug

Signed-off-by: yuye-aws <[email protected]>
opensearch-project · Apr 2, 2024 · 5eb848b · 5eb848b
1 parent 74f29b4
commit 5eb848b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...ade/src/test/java/org/opensearch/neuralsearch/bwc/AbstractRestartUpgradeRestTestCase.java b/...ade/src/test/java/org/opensearch/neuralsearch/bwc/AbstractRestartUpgradeRestTestCase.java
@@ -106,6 +106,6 @@ protected void createPipelineForTextChunkingProcessor(String pipelineName) throw
         URL pipelineURLPath = classLoader.getResource("processor/PipelineForTextChunkingProcessorConfiguration.json");
         Objects.requireNonNull(pipelineURLPath);
         String requestBody = Files.readString(Path.of(pipelineURLPath.toURI()));
-        createPipelineProcessor(requestBody, pipelineName);
+        createPipelineProcessorWithoutModelId(requestBody, pipelineName);
     }
 }
diff --git a/...upgrade/src/test/java/org/opensearch/neuralsearch/bwc/AbstractRollingUpgradeTestCase.java b/...upgrade/src/test/java/org/opensearch/neuralsearch/bwc/AbstractRollingUpgradeTestCase.java
@@ -137,6 +137,6 @@ protected void createPipelineForTextChunkingProcessor(String pipelineName) throw
         URL pipelineURLPath = classLoader.getResource("processor/PipelineForTextChunkingProcessorConfiguration.json");
         Objects.requireNonNull(pipelineURLPath);
         String requestBody = Files.readString(Path.of(pipelineURLPath.toURI()));
-        createPipelineProcessor(requestBody, pipelineName);
+        createPipelineProcessorWithoutModelId(requestBody, pipelineName);
     }
 }
diff --git a/src/testFixtures/java/org/opensearch/neuralsearch/BaseNeuralSearchIT.java b/src/testFixtures/java/org/opensearch/neuralsearch/BaseNeuralSearchIT.java
@@ -291,7 +291,7 @@ protected void createPipelineProcessor(final String modelId, final String pipeli
         createPipelineProcessor(requestBody, pipelineName, modelId);
     }
 
-    protected void createPipelineProcessor(final String requestBody, final String pipelineName) throws Exception {
+    protected void createPipelineProcessorWithoutModelId(final String requestBody, final String pipelineName) throws Exception {
         Response pipelineCreateResponse = makeRequest(
             client(),
             "PUT",