diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index 0c0fe2e..8ab3757 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -255,7 +255,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { if err != nil { switch err { - case reddit.ErrTimeout: // Don't log timeouts + case reddit.ErrTimeout, reddit.ErrRateLimited: // Don't log timeouts or rate limits break case reddit.ErrOauthRevoked: err = nc.deleteAccount(account) diff --git a/internal/worker/stuck_notifications.go b/internal/worker/stuck_notifications.go index 7a82d1a..1ede379 100644 --- a/internal/worker/stuck_notifications.go +++ b/internal/worker/stuck_notifications.go @@ -152,9 +152,11 @@ func (snc *stuckNotificationsConsumer) Consume(delivery rmq.Delivery) { things, err = rac.MessageInbox(snc) if err != nil { - snc.logger.WithFields(logrus.Fields{ - "err": err, - }).Error("failed to fetch last thing via inbox") + if err != reddit.ErrRateLimited { + snc.logger.WithFields(logrus.Fields{ + "err": err, + }).Error("failed to fetch last thing via inbox") + } return } } else {