diff options
Diffstat (limited to 'internal/worker/worker.go')
| -rw-r--r-- | internal/worker/worker.go | 18 |
1 files changed, 14 insertions, 4 deletions
diff --git a/internal/worker/worker.go b/internal/worker/worker.go index 8cd59a56..d7cd2e8c 100644 --- a/internal/worker/worker.go +++ b/internal/worker/worker.go @@ -4,10 +4,10 @@ package worker // import "miniflux.app/v2/internal/worker" import ( + "log/slog" "time" "miniflux.app/v2/internal/config" - "miniflux.app/v2/internal/logger" "miniflux.app/v2/internal/metric" "miniflux.app/v2/internal/model" feedHandler "miniflux.app/v2/internal/reader/handler" @@ -22,11 +22,17 @@ type Worker struct { // Run wait for a job and refresh the given feed. func (w *Worker) Run(c chan model.Job) { - logger.Debug("[Worker] #%d started", w.id) + slog.Debug("Worker started", + slog.Int("worker_id", w.id), + ) for { job := <-c - logger.Debug("[Worker #%d] Received feed #%d for user #%d", w.id, job.FeedID, job.UserID) + slog.Debug("Job received by worker", + slog.Int("worker_id", w.id), + slog.Int64("user_id", job.UserID), + slog.Int64("feed_id", job.FeedID), + ) startTime := time.Now() refreshErr := feedHandler.RefreshFeed(w.store, job.UserID, job.FeedID, false) @@ -40,7 +46,11 @@ func (w *Worker) Run(c chan model.Job) { } if refreshErr != nil { - logger.Error("[Worker] Refreshing the feed #%d returned this error: %v", job.FeedID, refreshErr) + slog.Warn("Unable to refresh a feed", + slog.Int64("user_id", job.UserID), + slog.Int64("feed_id", job.FeedID), + slog.Any("error", refreshErr), + ) } } } |