moving to snapshot status when adding table (#1404)

Co-authored-by: Kaushik Iska <[email protected]>
PeerDB-io · Feb 29, 2024 · 449b86f · 449b86f
1 parent b7db2ad
commit 449b86f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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,