diff --git a/flow/workflows/xmin_flow.go b/flow/workflows/xmin_flow.go
index 3c265fdbdc..cfad161074 100644
--- a/flow/workflows/xmin_flow.go
+++ b/flow/workflows/xmin_flow.go
@@ -238,8 +238,17 @@ func XminFlowWorkflow(
 		return fmt.Errorf("xmin replication failed: %w", err)
 	}
 
+	lpIDSideEffect := workflow.SideEffect(ctx, func(ctx workflow.Context) interface{} {
+		return uuid.New().String()
+	})
+
+	var lpID string
+	if err := lpIDSideEffect.Get(&lpID); err != nil {
+		return fmt.Errorf("failed to get last partition id: %w", err)
+	}
+
 	state.LastPartition = &protos.QRepPartition{
-		PartitionId: uuid.New().String(),
+		PartitionId: lpID,
 		Range:       &protos.PartitionRange{Range: &protos.PartitionRange_IntRange{IntRange: &protos.IntPartitionRange{Start: lastPartition}}},
 	}