diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go index 382efb3a26..16d5c371f3 100644 --- a/flow/workflows/cdc_flow.go +++ b/flow/workflows/cdc_flow.go @@ -157,6 +157,7 @@ func (w *CDCFlowWorkflowExecution) processCDCFlowConfigUpdate(ctx workflow.Conte w.logger.Warn("duplicate source/destination tables found in additionalTables") return nil } + state.CurrentFlowStatus = protos.FlowStatus_STATUS_SNAPSHOT alterPublicationAddAdditionalTablesCtx := workflow.WithActivityOptions(ctx, workflow.ActivityOptions{ StartToCloseTimeout: 5 * time.Minute,