|
|
|
@ -103,7 +103,7 @@ func (w *worker) maybeRunJob() time.Duration {
|
|
|
|
|
return _timeoutNoJob |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
jobs := w.dashboard.addJob(w.id, job) |
|
|
|
|
number := w.dashboard.addJob(w.id, job) |
|
|
|
|
defer w.dashboard.removeJob(w.id) |
|
|
|
|
|
|
|
|
|
logger, err := w.cloneLogger(job) |
|
|
|
@ -119,7 +119,8 @@ func (w *worker) maybeRunJob() time.Duration {
|
|
|
|
|
logger.Info( //:::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::::
|
|
|
|
|
"Worker", |
|
|
|
|
"id", w.id, |
|
|
|
|
"jobs", jobs, |
|
|
|
|
"job", job.ID, |
|
|
|
|
"number", fmt.Sprintf("n°%d", number), |
|
|
|
|
) |
|
|
|
|
|
|
|
|
|
w.runner.RunJob(job, logger) |
|
|
|
|