fixing workflowrequest

Signed-off-by: Joshua Palis <[email protected]>
opensearch-project · Aug 5, 2024 · 8ffa29d · 8ffa29d
1 parent aa2ce8a
commit 8ffa29d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java b/src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java
@@ -162,7 +162,7 @@ public WorkflowRequest(StreamInput in) throws IOException {
         this.params = provisionOrUpdateOrReprovision
             ? in.readMap(StreamInput::readString, StreamInput::readString)
             : Collections.emptyMap();
-        this.provision = provisionOrUpdateOrReprovision && params.isEmpty();
+        this.provision = provisionOrUpdateOrReprovision && !params.containsKey(UPDATE_WORKFLOW_FIELDS) && !params.containsKey(REPROVISION_WORKFLOW);
         this.updateFields = !provision && Boolean.parseBoolean(params.get(UPDATE_WORKFLOW_FIELDS));
         if (this.updateFields) {
             this.params = Collections.emptyMap();