1113
executionTime time.Time,
1114
taskQueue string,
1116
>
s.taskID++
1117
>
workflowExecution := commonpb.WorkflowExecution{
1118
>
WorkflowId: workflowID,
1119
>
RunId: uuid.NewString(),
1120
>
}
1121
>
startReq := &manager.RecordWorkflowExecutionStartedRequest{
1122
>
VisibilityRequestBase: &manager.VisibilityRequestBase{
1123
>
NamespaceID: namespaceID,
1124
>
Execution: &workflowExecution,
1125
>
WorkflowTypeName: workflowType,
1126
>
StartTime: startTime,
1127
>
ExecutionTime: executionTime,
1128
>
Status: enumspb.WORKFLOW_EXECUTION_STATUS_RUNNING,
1129
>
TaskQueue: taskQueue,
1130
>
TaskID: s.taskID,
1131
>
},
1132
>
}
1133
>
err := s.VisibilityMgr.RecordWorkflowExecutionStarted(s.ctx, startReq)
1134
>
s.NoError(err)
1135
>
return startReq
1136
>
}
1137
1138
func (s *VisibilityPersistenceSuite) assertClosedExecutionEquals(