From ecd48bad355f80bd38474eecd7298ede48a62b3f Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Mon, 4 Dec 2023 23:21:56 +0530 Subject: [PATCH] uses waitseconds as partitionid --- flow/cmd/handler.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/flow/cmd/handler.go b/flow/cmd/handler.go index c3eefadfb5..1d847a3a89 100644 --- a/flow/cmd/handler.go +++ b/flow/cmd/handler.go @@ -3,6 +3,7 @@ package main import ( "context" "fmt" + "strconv" "strings" "time" @@ -251,6 +252,10 @@ func (h *FlowRequestHandler) CreateQRepFlow( var workflowFn interface{} if cfg.SourcePeer.Type == protos.DBType_POSTGRES && cfg.WatermarkColumn == "xmin" { state.LastPartition.PartitionId = "" + if cfg.WaitBetweenBatchesSeconds > 0 { + log.Info("Starting XMIN from :", cfg.WaitBetweenBatchesSeconds) + state.LastPartition.PartitionId = strconv.FormatUint(uint64(cfg.WaitBetweenBatchesSeconds), 10) + } workflowFn = peerflow.XminFlowWorkflow } else { workflowFn = peerflow.QRepFlowWorkflow