diff --git a/src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java b/src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java index 31207cf4a..a258e6e10 100644 --- a/src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java +++ b/src/main/java/org/opensearch/flowframework/transport/WorkflowRequest.java @@ -162,7 +162,9 @@ public WorkflowRequest(StreamInput in) throws IOException { this.params = provisionOrUpdateOrReprovision ? in.readMap(StreamInput::readString, StreamInput::readString) : Collections.emptyMap(); - this.provision = provisionOrUpdateOrReprovision && !params.containsKey(UPDATE_WORKFLOW_FIELDS) && !params.containsKey(REPROVISION_WORKFLOW); + 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();