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 {