Converting to structured logging the file jobs/jobs_watcher.go (#12121)
Этот коммит содержится в:
коммит произвёл
Joram Wilander
родитель
63552416fb
Коммит
8b969426f0
@@ -4,7 +4,6 @@
|
|||||||
package jobs
|
package jobs
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"math/rand"
|
"math/rand"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -68,7 +67,7 @@ func (watcher *Watcher) Stop() {
|
|||||||
func (watcher *Watcher) PollAndNotify() {
|
func (watcher *Watcher) PollAndNotify() {
|
||||||
jobs, err := watcher.srv.Store.Job().GetAllByStatus(model.JOB_STATUS_PENDING)
|
jobs, err := watcher.srv.Store.Job().GetAllByStatus(model.JOB_STATUS_PENDING)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
mlog.Error(fmt.Sprintf("Error occurred getting all pending statuses: %v", err.Error()))
|
mlog.Error("Error occurred getting all pending statuses.", mlog.Err(err))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user