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