diff --git a/flow/activities/flowable.go b/flow/activities/flowable.go
index 07bd946493..7fdf8cf812 100644
--- a/flow/activities/flowable.go
+++ b/flow/activities/flowable.go
@@ -590,6 +590,7 @@ func (a *FlowableActivity) ReplicateQRepPartitions(ctx context.Context,
 	)
 	for i, p := range partitions.Partitions {
 		logger.Info(fmt.Sprintf("batch-%d - waiting for 20 seconds before replicating partition - %s",
+			partitions.BatchId, p.PartitionId))
 		time.Sleep(20 * time.Second)
 
 		logger.Info(fmt.Sprintf("batch-%d - replicating partition - %s", partitions.BatchId, p.PartitionId))