moving to snapshot status when adding table

PeerDB-io · Feb 29, 2024 · 0662890 · 0662890
1 parent b6eb5d1
commit 0662890
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,