diff options
Diffstat (limited to 'flow-cleaner.go')
| -rw-r--r-- | flow-cleaner.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/flow-cleaner.go b/flow-cleaner.go index 71c1196..e840c41 100644 --- a/flow-cleaner.go +++ b/flow-cleaner.go @@ -39,10 +39,11 @@ func processFromStdin(cfg *Config) { input := readFromStdin() rDatChan := parseRawData(input, cfg) cleanFromStdin(rDatChan, cfg) + logger.Println("Finished processing from stdin!") } func processFromDB(cfg *Config) { - logger.Print("Cleaning data...") + logger.Print("Starting to process from db...") starttime := time.Now() numOfRowsNotCleaned, err := cleanFromDB(cfg) if err != nil { @@ -50,7 +51,7 @@ func processFromDB(cfg *Config) { logger.Println("Exiting...") return } - logger.Println("Done!") + logger.Println("Finished processing from db!") // If either all rows are processed or if there is no limit for the processing // we can safely add noise to the cleaned data |