76
request.Clock,
77
func(mutableState historyi.MutableState) bool {
78
>
if !mutableState.IsWorkflowExecutionRunning() {
api.go
79
// current branch already closed, we won't perform any operation, pass the check
80
return true
81
}
82
83
>
onCurrentBranch, err := api.IsHistoryEventOnCurrentBranch(mutableState, parentInitiatedID, parentInitiatedVersion)
api.go
84
>
if err != nil {
85
// can't find initiated event, potential stale mutable, fail the predicate check
86
return false
87
}
88
>
if !onCurrentBranch {
api.go
89
// found on different branch, since we don't record completion on a different branch, pass the check
90
return true
91
}
92
93
>
_, childInitEventFound := mutableState.GetChildExecutionInfo(parentInitiatedID)
api.go
94
>
return childInitEventFound
95
},
96
definition.NewWorkflowKey(