swapping order of addpub and ensurepullability

PeerDB-io · Feb 19, 2024 · ebca80a · ebca80a
1 parent d984ff5
commit ebca80a
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/flow/workflows/cdc_flow.go b/flow/workflows/cdc_flow.go
@@ -152,18 +152,6 @@ func (w *CDCFlowWorkflowExecution) processCDCFlowConfigUpdates(ctx workflow.Cont
 			continue
 		}
 
-		alterPublicationAddAdditionalTablesCtx := workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
-			StartToCloseTimeout: 5 * time.Minute,
-		})
-		alterPublicationAddAdditionalTablesFuture := workflow.ExecuteActivity(
-			alterPublicationAddAdditionalTablesCtx,
-			flowable.AddTablesToPublication,
-			cfg, flowConfigUpdate.AdditionalTables)
-		if err := alterPublicationAddAdditionalTablesFuture.Get(ctx, nil); err != nil {
-			w.logger.Error("failed to alter publication for additional tables: ", err)
-			return err
-		}
-
 		ensurePullabilityCtx := workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
 			StartToCloseTimeout: 5 * time.Minute,
 		})
@@ -187,6 +175,18 @@ func (w *CDCFlowWorkflowExecution) processCDCFlowConfigUpdates(ctx workflow.Cont
 			return err
 		}
 
+		alterPublicationAddAdditionalTablesCtx := workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
+			StartToCloseTimeout: 5 * time.Minute,
+		})
+		alterPublicationAddAdditionalTablesFuture := workflow.ExecuteActivity(
+			alterPublicationAddAdditionalTablesCtx,
+			flowable.AddTablesToPublication,
+			cfg, flowConfigUpdate.AdditionalTables)
+		if err := alterPublicationAddAdditionalTablesFuture.Get(ctx, nil); err != nil {
+			w.logger.Error("failed to alter publication for additional tables: ", err)
+			return err
+		}
+
 		additionalTablesWorkflowCfg := proto.Clone(cfg).(*protos.FlowConnectionConfigs)
 		additionalTablesWorkflowCfg.DoInitialSnapshot = true
 		additionalTablesWorkflowCfg.InitialSnapshotOnly = true