diff options
| -rw-r--r-- | cleaner.go | 4 |
1 files changed, 4 insertions, 0 deletions
@@ -19,6 +19,7 @@ func init() { } func cleanFromDB(cfg *Config) (rowsLeft int, err error) { + cllogger.Println("Starting to clean from db...") db, err := sql.Open("mysql", cfg.DBUser+":"+cfg.DBPass+"@"+cfg.DBConn+"/"+cfg.DBName) if err != nil { @@ -82,10 +83,12 @@ func cleanFromDB(cfg *Config) (rowsLeft int, err error) { } tx.Commit() + cllogger.Println("Finished cleaning from db!") return } func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error { + cllogger.Println("Starting to clean from stdin") for rDat := range rDatChan { cDat, err := clean(rDat, cfg) if err != nil { @@ -98,6 +101,7 @@ func cleanFromStdin(rDatChan <-chan []RawData, cfg *Config) error { return err } } + cllogger.Println("Finished cleaning from stdin!") return nil } |