Fix record child completion mutable state stale check (#2885)

temporalio · May 21, 2022 · 3fff3f0 · 3fff3f0
1 parent dc39bc7
commit 3fff3f0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/service/history/historyEngine.go b/service/history/historyEngine.go
@@ -2401,7 +2401,8 @@ func (e *historyEngineImpl) RecordChildExecutionCompleted(
 
 			// Check mutable state to make sure child execution is in pending child executions
 			ci, isRunning := mutableState.GetChildExecutionInfo(initiatedID)
-			if !isRunning && initiatedID >= mutableState.GetNextEventID() {
+			if (!isRunning && initiatedID >= mutableState.GetNextEventID()) ||
+				(isRunning && ci.StartedId == common.EmptyEventID) {
 				// possible stale mutable state, try reload mutable state
 				//
 				// TODO: use initiate event ID and version to verify if the child exists or not