74
logger.Warn(warnMsg, tag.Error(err))
75
warnings = append(warnings, fmt.Sprintf("%s. Error: %v", warnMsg, err.Error()))
77
>
// load necessary information from mutable state
78
>
executionInfo := resp.State.GetExecutionInfo()
79
>
histories := executionInfo.GetVersionHistories().GetHistories()
80
>
branchTokens = make([][]byte, 0, len(histories))
81
>
for _, versionHistory := range histories {
82
>
branchToken := versionHistory.GetBranchToken()
83
>
if len(branchToken) != 0 {
84
>
// non-workflow executions have empty version history and empty branch token
85
>
branchTokens = append(branchTokens, branchToken)
86
>
}
87
}
88
>
startTime = resp.State.GetExecutionState().GetStartTime().AsTime()
api.go
89
>
closeTime = new(executionInfo.GetCloseTime().AsTime())
90
>
if !closeTime.After(time.Unix(0, 0)) {
91
>
closeTime = nil
92
>
}
93
}
94