diff --git a/internal/worker/worker.go b/internal/worker/worker.go index d7cd2e8c..d8195f97 100644 --- a/internal/worker/worker.go +++ b/internal/worker/worker.go @@ -35,21 +35,21 @@ func (w *Worker) Run(c chan model.Job) { ) startTime := time.Now() - refreshErr := feedHandler.RefreshFeed(w.store, job.UserID, job.FeedID, false) + localizedError := feedHandler.RefreshFeed(w.store, job.UserID, job.FeedID, false) if config.Opts.HasMetricsCollector() { status := "success" - if refreshErr != nil { + if localizedError != nil { status = "error" } metric.BackgroundFeedRefreshDuration.WithLabelValues(status).Observe(time.Since(startTime).Seconds()) } - if refreshErr != nil { + if localizedError != nil { slog.Warn("Unable to refresh a feed", slog.Int64("user_id", job.UserID), slog.Int64("feed_id", job.FeedID), - slog.Any("error", refreshErr), + slog.Any("error", localizedError.Error()), ) } }