Subtask executes specified subtasks
(subtaskMeta plugin.SubTaskMeta, taskData interface{})
| 217 | |
| 218 | // Subtask executes specified subtasks |
| 219 | func (t *DataFlowTester) Subtask(subtaskMeta plugin.SubTaskMeta, taskData interface{}) { |
| 220 | t.FlushTabler(&models.SubtaskState{}) |
| 221 | subtaskCtx := t.SubtaskContext(taskData) |
| 222 | err := subtaskMeta.EntryPoint(subtaskCtx) |
| 223 | if err != nil { |
| 224 | panic(err) |
| 225 | } |
| 226 | } |
| 227 | |
| 228 | // SubtaskContext creates a subtask context |
| 229 | func (t *DataFlowTester) SubtaskContext(taskData interface{}) plugin.SubTaskContext { |