fix: skip for table addition and resync

Author: Amogh-Bharadwaj

flow/workflows/setup_flow.go

@@ -5,6 +5,7 @@ import (
 	"log/slog"
 	"maps"
 	"slices"
+	"strings"
 	"time"
 
 	"go.temporal.io/sdk/log"
@@ -273,6 +274,17 @@ func (s *SetupFlowExecution) runPgDumpSchema(
 	return ran, nil
 }
 
+// isTableAdditionChild reports whether this SetupFlow was launched as part of a
+// table-addition child CDC flow. Such workflows are spawned with a parent
+// workflow ID prefixed by "additional-cdc-flow-".
+func isTableAdditionChild(ctx workflow.Context) bool {
+	parent := workflow.GetInfo(ctx).ParentWorkflowExecution
+	if parent == nil {
+		return false
+	}
+	return strings.HasPrefix(parent.ID, "additional-cdc-flow-")
+}
+
 // getPGAutomatedSchemaDump checks the PEERDB_PG_AUTOMATED_SCHEMA_DUMP env flag via an activity.
 func (s *SetupFlowExecution) getPGAutomatedSchemaDump(ctx workflow.Context, env map[string]string) bool {
 	checkCtx := workflow.WithActivityOptions(ctx, workflow.ActivityOptions{
@@ -319,8 +331,11 @@ func (s *SetupFlowExecution) executeSetupFlow(
 
 	// pg_dump silently no-ops for SSH tunnel / non-password-auth peers, so we
 	// only skip CreateNormalizedTable when the activity reports it actually ran.
+	// Skip pg_dump for resync (tables get _resync suffix and are swapped) and for
+	// table-addition child workflows (parent workflow ID prefix "additional-cdc-flow-").
 	skipCreateTables := false
-	if config.System == protos.TypeSystem_PG && s.getPGAutomatedSchemaDump(ctx, config.Env) {
+	if config.System == protos.TypeSystem_PG && !config.Resync && !isTableAdditionChild(ctx) &&
+		s.getPGAutomatedSchemaDump(ctx, config.Env) {
 		ran, err := s.runPgDumpSchema(ctx, config)
 		if err != nil {
 			return nil, fmt.Errorf("failed to run pg_dump schema migration: %w", err)