diff options
author | Daniel Langesten <daniel.langest@gmail.com> | 2015-03-25 15:30:07 +0100 |
---|---|---|
committer | Daniel Langesten <daniel.langest@gmail.com> | 2015-03-25 15:30:07 +0100 |
commit | 42811bebad023e591c5b8fbc1122c62f77a375d9 (patch) | |
tree | a057ae00c4b99e6802168d2eac1ac1e6a77ed23b | |
parent | cb49c577aa7f1b88f2b65568ac2edd6cc672bd7c (diff) |
fixed so it doesnt quit processing stdin if data fails but rather throw away the data
-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!") |