diff --git a/workers.go b/workers.go index b344a96..2b6b24f 100644 --- a/workers.go +++ b/workers.go @@ -143,6 +143,9 @@ func SQLJobWorker(id int) { for true { jobs, err := loadCurrentJobs() logOnError(err, "SQLJobWorker["+strconv.Itoa(id)+"] : loadCurrentJobs") + if len(jobs) > 0 { + log.Printf("SQLJobWorker["+strconv.Itoa(id)+"] : %d jobs.\n", len(jobs)) + } if len(jobs) < SQLJobSliceSize { time.Sleep(100 * time.Millisecond) }