From 46d43944a014169aa8406679d2fa2af8a95524ff Mon Sep 17 00:00:00 2001
From: Kaushik Iska <iska.kaushik@gmail.com>
Date: Wed, 6 Mar 2024 10:01:44 -0500
Subject: [PATCH] sleep 20

---
 flow/activities/flowable.go | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index 3900d07385..07bd946493 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -589,6 +589,9 @@ func (a *FlowableActivity) ReplicateQRepPartitions(ctx context.Context,
 		partitions.BatchId, numPartitions),
 	)
 	for i, p := range partitions.Partitions {
+		logger.Info(fmt.Sprintf("batch-%d - waiting for 20 seconds before replicating partition - %s",
+		time.Sleep(20 * time.Second)
+
 		logger.Info(fmt.Sprintf("batch-%d - replicating partition - %s", partitions.BatchId, p.PartitionId))
 		err := a.replicateQRepPartition(ctx, config, i+1, numPartitions, p, runUUID)
 		if err != nil {