1080
runTimeoutTimer := r.mutableState.GetExecutionInfo().WorkflowRunExpirationTime
1081
if !timeNotSet(runTimeoutTimer) {
1082
>
// Version must match the workflow's start version so the executor's
task_generator.go
1083
>
// CheckTaskVersion passes for global namespaces (see timer_queue_active_task_executor.go).
1084
>
startVersion, err := r.mutableState.GetStartVersion()
1085
>
if err != nil {
1086
return err
1087
}
1089
>
// TaskID is set by shard
1090
>
WorkflowKey: r.mutableState.GetWorkflowKey(),
1091
>
VisibilityTimestamp: timestamp.TimeValue(runTimeoutTimer),
1092
>
Version: startVersion,
1093
>
})
1094
}
1095