Fix panic on error deleting messages

natenho · Sep 4, 2023 · 5cebacf · 5cebacf
1 parent 82f86f9
commit 5cebacf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/main.go b/main.go
@@ -256,6 +256,7 @@ func deleteSQSMessages(ctx context.Context, batch []types.Message, sqsClient *sq
 
 	if err != nil {
 		log.Printf("Error deleting message: %v", err)
+		return
 	}
 
 	log.Printf("Deleted %d Failed %d", len(result.Successful), len(result.Failed))