1085
closeTime time.Time,
1086
status enumspb.WorkflowExecutionStatus,
1088
>
s.taskID++
1089
>
closeReq := &manager.RecordWorkflowExecutionClosedRequest{
1090
>
VisibilityRequestBase: &manager.VisibilityRequestBase{
1091
>
NamespaceID: startReq.NamespaceID,
1092
>
Execution: startReq.Execution,
1093
>
WorkflowTypeName: startReq.WorkflowTypeName,
1094
>
StartTime: startReq.StartTime,
1095
>
ExecutionTime: startReq.ExecutionTime,
1096
>
Status: status,
1097
>
TaskID: s.taskID,
1098
>
},
1099
>
CloseTime: closeTime,
1100
>
ExecutionDuration: closeTime.Sub(startReq.ExecutionTime),
1101
>
HistoryLength: 5,
1102
>
}
1103
>
err := s.VisibilityMgr.RecordWorkflowExecutionClosed(s.ctx, closeReq)
1104
>
s.NoError(err)
1105
>
return closeReq
1106
>
}
1107
1108
func (s *VisibilityPersistenceSuite) createOpenWorkflowRecord(