diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
index bd1d5459d..0c97af9b7 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)