diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index b4e3a21..a90644a 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -184,7 +184,9 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { account, err := nc.accountRepo.GetByRedditID(ctx, id) if err != nil { - logger.Info("account not found, exiting", zap.Error(err)) + if err != domain.ErrNotFound { + logger.Debug("could not fetch account", zap.Error(err)) + } return }