Fix childWF decision panic after reset due to runID change (#1118)

Author: longquanzheng

internal/internal_event_handlers.go

@@ -374,7 +374,11 @@ func (wc *workflowEnvironmentImpl) RegisterCancelHandler(handler func()) {
 func (wc *workflowEnvironmentImpl) ExecuteChildWorkflow(
 	params executeWorkflowParams, callback resultHandler, startedHandler func(r WorkflowExecution, e error)) error {
 	if params.workflowID == "" {
-		params.workflowID = wc.workflowInfo.WorkflowExecution.RunID + "_" + wc.GenerateSequenceID()
+		if wc.workflowInfo.OriginalRunId != ""{
+			params.workflowID = wc.workflowInfo.OriginalRunId + "_" + wc.GenerateSequenceID()	
+		}else{
+			params.workflowID = wc.workflowInfo.WorkflowExecution.RunID + "_" + wc.GenerateSequenceID()
+		}
 	}
 	memo, err := getWorkflowMemo(params.memo, wc.dataConverter)
 	if err != nil {

internal/internal_task_handlers.go

@@ -633,6 +633,7 @@ func (wth *workflowTaskHandlerImpl) createWorkflowContext(task *s.PollForDecisio
 			ID:    workflowID,
 			RunID: runID,
 		},
+		OriginalRunId:                       attributes.GetOriginalExecutionRunId(),
 		WorkflowType:                        flowWorkflowTypeFrom(*task.WorkflowType),
 		TaskListName:                        taskList.GetName(),
 		ExecutionStartToCloseTimeoutSeconds: attributes.GetExecutionStartToCloseTimeoutSeconds(),

internal/workflow.go

@@ -779,6 +779,7 @@ func getWorkflowHeader(ctx Context, ctxProps []ContextPropagator) *s.Header {
 // WorkflowInfo information about currently executing workflow
 type WorkflowInfo struct {
 	WorkflowExecution                   WorkflowExecution
+	OriginalRunId                       string // The original runID before resetting. Using it instead of current runID can make workflow decision determinstic after reset 
 	WorkflowType                        WorkflowType
 	TaskListName                        string
 	ExecutionStartToCloseTimeoutSeconds int32