sleep 20

PeerDB-io · Mar 6, 2024 · 46d4394 · 46d4394
1 parent 0a32419
commit 46d4394
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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 {