SubtaskContext creates a subtask context
(taskData interface{})
| 227 | |
| 228 | // SubtaskContext creates a subtask context |
| 229 | func (t *DataFlowTester) SubtaskContext(taskData interface{}) plugin.SubTaskContext { |
| 230 | syncPolicy := &models.SyncPolicy{ |
| 231 | TriggerSyncPolicy: models.TriggerSyncPolicy{ |
| 232 | FullSync: true, |
| 233 | }, |
| 234 | } |
| 235 | return contextimpl.NewStandaloneSubTaskContext(context.Background(), runner.CreateBasicRes(t.Cfg, t.Log, t.Db), t.Name, taskData, t.Name, syncPolicy) |
| 236 | } |
| 237 | |
| 238 | func filterColumn(column dal.ColumnMeta, opts TableOptions) bool { |
| 239 | for _, ignore := range opts.IgnoreFields { |
no outgoing calls