From 42811bebad023e591c5b8fbc1122c62f77a375d9 Mon Sep 17 00:00:00 2001 From: Daniel Langesten Date: Wed, 25 Mar 2015 15:30:07 +0100 Subject: fixed so it doesnt quit processing stdin if data fails but rather throw away the data --- cleaner.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/cleaner.go b/cleaner.go index 3058730..5e0e7d0 100644 --- a/cleaner.go +++ b/cleaner.go @@ -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!") -- cgit v1.1