fix a4992dd ("fix: pgqueue: Add utils.Retriable to test weither an er…

…ror is retriable", 2023-10-16)
airbusgeo · Sep 20, 2024 · 696ee80 · 696ee80
1 parent 4e745a1
commit 696ee80
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/interface/messaging/pgqueue/pgqueue.go b/interface/messaging/pgqueue/pgqueue.go
@@ -98,7 +98,7 @@ func (p *Publisher) publish(ctx context.Context, retry int, data ...[]byte) erro
 	for _, d := range data {
 		jobID, err := p.worker.EnqueueJob(p.queueName, d, opts...)
 		if err != nil {
-			if !utils.Retriable(err) || p.maxRetries >= retry {
+			if !utils.Retriable(err) || retry >= p.maxRetries {
 				return fmt.Errorf("pgQueue.Publish: %w", err)
 			}
 			retryIds = append(retryIds, jobID)