From 0431320a7272f3986bf33bfbe351f8433041b745 Mon Sep 17 00:00:00 2001 From: shoopea Date: Thu, 25 Jun 2020 19:10:48 +0200 Subject: [PATCH] test --- workers.go | 1 + 1 file changed, 1 insertion(+) diff --git a/workers.go b/workers.go index 42c6660..b545469 100644 --- a/workers.go +++ b/workers.go @@ -630,6 +630,7 @@ func JobWorker(id int, jobs <-chan Job) { //log.Printf("jobWorker[" + strconv.Itoa(id) + "] : Starting.") // FIXME : discard timed out jobs for j := range jobs { + log.Printf("JobWorker[%d] : Starting job %d (timeout : %s).\n", id, j.ID64, j.Timeout.Format(time.RFC3339)) if time.Now().UTC().Before(j.Timeout) { switch j.JobTypeID64 { case cacheObjSubType[`job_rescan_msg`]: