From 4f3acbc282afa336499514f835c89b80558d23f6 Mon Sep 17 00:00:00 2001 From: "i.navrotskyj" Date: Wed, 10 Jul 2024 15:56:21 +0300 Subject: [PATCH] WTEL-4748 --- queue/queue_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/queue/queue_manager.go b/queue/queue_manager.go index 97ce1a8..5c332b3 100644 --- a/queue/queue_manager.go +++ b/queue/queue_manager.go @@ -1049,7 +1049,7 @@ func (queueManager *QueueManager) ReportingAttempt(attemptId int64, result model if err != nil { attempt.Log(err.Error()) } - if err != errNotFoundConnection { + if err != errNotFoundConnection && attempt.state != model.MemberStateProcessing { return err } }