Skip to content

Commit

Permalink
pick child workflow id check
Browse files Browse the repository at this point in the history
  • Loading branch information
yux0 authored Feb 18, 2021
1 parent 4b548e2 commit 0f2f75c
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions service/history/historyEngine.go
Original file line number Diff line number Diff line change
Expand Up @@ -2399,6 +2399,9 @@ func (e *historyEngineImpl) RecordChildExecutionCompleted(
if !isRunning || ci.StartedID == common.EmptyEventID {
return &types.EntityNotExistsError{Message: "Pending child execution not found."}
}
if ci.StartedWorkflowID != completedExecution.GetWorkflowID() {
return &types.EntityNotExistsError{Message: "Pending child execution not found."}
}

switch *completionEvent.EventType {
case types.EventTypeWorkflowExecutionCompleted:
Expand Down

0 comments on commit 0f2f75c

Please sign in to comment.