diff --git a/workers.go b/workers.go index d076e71..254a3f3 100644 --- a/workers.go +++ b/workers.go @@ -226,6 +226,7 @@ func SQLJobWorker() { func JobWorker(id int, jobs <-chan Job) { //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") for j := range jobs { + log.Printf("JobWorker[%d] : Starting job %d.\n", id, j.ID64) switch j.JobTypeID { case objSubTypeJobRescanMsg: jobRescan(j)