diff --git a/src/main/java/org/opensearch/flowframework/workflow/CreateIngestPipelineStep.java b/src/main/java/org/opensearch/flowframework/workflow/CreateIngestPipelineStep.java
index a425c967b..a9b73610d 100644
--- a/src/main/java/org/opensearch/flowframework/workflow/CreateIngestPipelineStep.java
+++ b/src/main/java/org/opensearch/flowframework/workflow/CreateIngestPipelineStep.java
@@ -54,7 +54,7 @@ public CompletableFuture<WorkflowData> execute(List<WorkflowData> data) {
             logger.debug("Previous step sent params: {}, content: {}", parameters, content);
 
             if (parameters.containsKey("id")) {
-                pipelineId = (String) parameters.get("id");
+                pipelineId = parameters.get("id");
             }
             if (content.containsKey("source")) {
                 source = (String) content.get("source");