From 3e2df303713a166a05b0714936df29b5d2d4c560 Mon Sep 17 00:00:00 2001 From: Nguyen Thanh Quang <57827456+AlphaNecron@users.noreply.github.com> Date: Mon, 13 Nov 2023 10:38:11 +0700 Subject: [PATCH] force `executor` to use attached logger instead of "log" package (#613) --- executor.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/executor.go b/executor.go index 9f5bee3..2bfe5eb 100644 --- a/executor.go +++ b/executor.go @@ -2,7 +2,6 @@ package gocron import ( "context" - "log" "strconv" "sync" "time" @@ -291,7 +290,7 @@ func (e *executor) limitModeRunner(name string, in chan uuid.UUID, wg *waitGroup for { select { case id := <-in: - log.Println("limitModeRunner got job", id) + e.logger.Info("limitModeRunner got job", id) select { case <-e.ctx.Done(): e.logger.Debug("limitModeRunner shutting down", "name", name) @@ -303,11 +302,11 @@ func (e *executor) limitModeRunner(name string, in chan uuid.UUID, wg *waitGroup ctx, cancel := context.WithCancel(e.ctx) j := requestJobCtx(ctx, id, e.jobOutRequest) if j != nil { - log.Println("limitModeRunner running job", id) + e.logger.Info("limitModeRunner running job", id) e.runJob(*j) } cancel() - log.Println("limitModeRunner finished job", id) + e.logger.Info("limitModeRunner finished job", id) // remove the limiter block to allow another job to be scheduled if limitMode == LimitModeReschedule { @@ -316,7 +315,7 @@ func (e *executor) limitModeRunner(name string, in chan uuid.UUID, wg *waitGroup default: } } - log.Println("limitModeRunner job done", id) + e.logger.Info("limitModeRunner job done", id) case <-e.ctx.Done(): e.logger.Debug("limitModeRunner shutting down", "name", name) wg.Done()