From 014e419151619330f3497486959620853b7b6222 Mon Sep 17 00:00:00 2001 From: Poorna Krishnamoorthy Date: Fri, 23 Apr 2021 16:52:57 -0700 Subject: [PATCH] fix: ensure pending replication queued to MRF queue (#12138) Signed-off-by: Poorna Krishnamoorthy --- cmd/bucket-replication.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cmd/bucket-replication.go b/cmd/bucket-replication.go index 63781d193..bc0808549 100644 --- a/cmd/bucket-replication.go +++ b/cmd/bucket-replication.go @@ -776,7 +776,7 @@ func replicateObject(ctx context.Context, ri ReplicateObjectInfo, objectAPI Obje } // re-queue failures once more - keep a retry count to avoid flooding the queue if // the target site is down. Leave it to scanner to catch up instead. - if replicationStatus == replication.Failed && ri.RetryCount < 1 { + if replicationStatus != replication.Completed && ri.RetryCount < 1 { ri.OpType = replication.HealReplicationType ri.RetryCount++ globalReplicationPool.queueReplicaTask(ctx, ri)