From 4c5e47e749648a4a5488a6bd491b5f5921910a20 Mon Sep 17 00:00:00 2001 From: Andre Medeiros Date: Sat, 14 Aug 2021 13:49:59 -0400 Subject: [PATCH] don't delete after any error --- internal/worker/notifications.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go index f505b16..1426c40 100644 --- a/internal/worker/notifications.go +++ b/internal/worker/notifications.go @@ -248,6 +248,7 @@ func (nc *notificationsConsumer) Consume(delivery rmq.Delivery) { "account#username": account.NormalizedUsername(), "err": err, }).Error("failed to fetch message inbox") + return } err = nc.deleteAccount(ctx, account)