[Fix #520] Refining before release

fjtirado · fjtirado · commit 75546dce72ba · 2025-01-31T12:29:00.000+01:00
diff --git a/impl/core/src/main/java/io/serverlessworkflow/impl/WorkflowInstance.java b/impl/core/src/main/java/io/serverlessworkflow/impl/WorkflowInstance.java
@@ -68,7 +68,7 @@ private JsonNode whenCompleted(JsonNode node) {
             .map(f -> f.apply(workflowContext, null, node))
             .orElse(node);
     workflowContext.definition().outputSchemaValidator().ifPresent(v -> v.validate(output));
-    status.set(WorkflowStatus.COMPLETED);
+    status.compareAndSet(WorkflowStatus.RUNNING, WorkflowStatus.COMPLETED);
     completedAt = Instant.now();
     return output;
   }

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ private JsonNode whenCompleted(JsonNode node) {`
`68`	`68`	`.map(f -> f.apply(workflowContext, null, node))`
`69`	`69`	`.orElse(node);`
`70`	`70`	`workflowContext.definition().outputSchemaValidator().ifPresent(v -> v.validate(output));`
`71`		`- status.set(WorkflowStatus.COMPLETED);`
	`71`	`+ status.compareAndSet(WorkflowStatus.RUNNING, WorkflowStatus.COMPLETED);`
`72`	`72`	`completedAt = Instant.now();`
`73`	`73`	`return output;`
`74`	`74`	`}`