From a1464c8c7701687d1571e3425a630033cb760f5b Mon Sep 17 00:00:00 2001 From: Amogh-Bharadwaj Date: Thu, 21 Nov 2024 02:55:18 +0530 Subject: [PATCH] minor change --- flow/workflows/cdc_flow.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index bd1d5459dd..0c97af9b7d 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -480,15 +480,15 @@ func CDCFlowWorkflow( } } - state.CurrentFlowStatus = protos.FlowStatus_STATUS_RUNNING logger.Info("executed setup flow and snapshot flow") - // if initial_copy_only is opted for, we end the flow here. if cfg.InitialSnapshotOnly { logger.Info("initial snapshot only, ending flow") state.CurrentFlowStatus = protos.FlowStatus_STATUS_COMPLETED return state, nil } + + state.CurrentFlowStatus = protos.FlowStatus_STATUS_RUNNING } syncFlowID := GetChildWorkflowID("sync-flow", cfg.FlowJobName, originalRunID)