diff options
| -rw-r--r-- | cleaner.go | 6 |
1 files changed, 4 insertions, 2 deletions
@@ -93,12 +93,14 @@ func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error { cDat, err := clean(rDat, cfg) if err != nil { cllogger.Println("Failed to clean data from stdin:", err) - return err + cllogger.Println("Skipping data:", cDat) + continue } err = insertCleanDataToDB(cfg, cDat) if err != nil { cllogger.Println("Failed to insert clean data from stdin:", err) - return err + cllogger.Println("Skipping data:", cDat) + continue } } cllogger.Println("Finished cleaning from stdin!") |
