diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index c7d7523..777d5eb 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -168,7 +168,9 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { account, err := nc.accountRepo.GetByRedditID(ctx, id) if err != nil { - nc.logger.Error("failed to fetch account from database", zap.Error(err), zap.String("account#reddit_account_id", id)) + nc.logger.Info("account not found, exiting", + zap.Error(err), + zap.String("account#reddit_account_id", id)) return }