(cfg ImportConfig)
| 73 | } |
| 74 | |
| 75 | func fetchImportTasks(cfg ImportConfig) ([]ExternalTask, error) { |
| 76 | src, err := GetSource(cfg.SourceName) |
| 77 | if err != nil { |
| 78 | return nil, err |
| 79 | } |
| 80 | if err := src.ValidateConfig(cfg.SourceCfg); err != nil { |
| 81 | return nil, fmt.Errorf("invalid config for source %q: %w", cfg.SourceName, err) |
| 82 | } |
| 83 | return src.FetchTasks(cfg.SourceCfg) |
| 84 | } |
| 85 | |
| 86 | func resolveImportFieldMap(sourceName string, userMap FieldMap) FieldMap { |
| 87 | fm := defaultImportFieldMap() |
no test coverage detected