diff --git a/workers.go b/workers.go index 14e1894..92f60c9 100644 --- a/workers.go +++ b/workers.go @@ -609,11 +609,11 @@ func SQLJobWorker() { for true { jobs, err := loadCurrentJobs() logOnError(err, "SQLJobWorker : loadCurrentJobs") - /* - if len(jobs) > 0 { - log.Printf("SQLJobWorker : %d jobs.\n", len(jobs)) - } - */ + + if len(jobs) > 0 { + log.Printf("SQLJobWorker : %d jobs.\n", len(jobs)) + } + if err == nil { for _, j := range jobs { JobQueue <- j