fix: Fixed running multiple workflows with mutex and memo concurrentl…

…y is broken (argoproj#11883) Signed-off-by: shmruin <[email protected]> Signed-off-by: Dillen Padhiar <[email protected]>
dpadhiar · May 9, 2024 · 71fc458 · 71fc458
1 parent 10d45cb
commit 71fc458
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/workflow/controller/operator.go b/workflow/controller/operator.go
@@ -1938,6 +1938,7 @@ func (woc *wfOperationCtx) executeTemplate(ctx context.Context, nodeName string,
 	if node != nil {
 		fulfilledNode := woc.handleNodeFulfilled(nodeName, node, processedTmpl)
 		if fulfilledNode != nil {
+			woc.controller.syncManager.Release(woc.wf, node.ID, processedTmpl.Synchronization)
 			return fulfilledNode, nil
 		}
 		// Memoized nodes don't have StartedAt.