diff options
Diffstat (limited to 'flow-cleaner.go')
| -rw-r--r-- | flow-cleaner.go | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/flow-cleaner.go b/flow-cleaner.go index f40f1c3..9e038cf 100644 --- a/flow-cleaner.go +++ b/flow-cleaner.go @@ -39,7 +39,10 @@ func processFromStdin(cfg *Config) { flogger.Println("Starting to process from stdin...") input := readFromStdin() rDatChan := parseRawData(input, cfg) - cleanFromStdin(rDatChan, cfg) + err := cleanFromStdin(rDatChan, cfg) + if err != nil { + flogger.Println("Failed to clean data:", err) + } flogger.Println("Finished processing from stdin!") } |