diff --git a/main.go b/main.go index 0118a47..f9a4586 100644 --- 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))