}
func (s *ExecutionMutableStateTaskSuite) TestAddGetCompleteScheduledTask_Single() {
execution_mutable_state_task.go
scheduledTasks := s.AddRandomTasks(
fakeScheduledTaskCategory,
1,
func(workflowKey definition.WorkflowKey, taskID int64, visibilityTimestamp time.Time) tasks.Task {
fakeTask := tasks.NewFakeTask(
workflowKey,
fakeScheduledTaskCategory,
visibilityTimestamp,
)
fakeTask.SetTaskID(taskID)
return fakeTask
},
)
s.GetAndCompleteHistoryTask(fakeScheduledTaskCategory, scheduledTasks[0])
execution_mutable_state_task.go
}