Skip to content

Commit 9232676

Browse files
authored
fix: Send delete stale when --no-migrate is used (#13310)
#### Summary Fixes #13281 <!--
1 parent fafeb7e commit 9232676

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

cli/cmd/sync_v3.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -197,15 +197,15 @@ func syncConnectionV3(ctx context.Context, sourceClient *managedplugin.Client, d
197197
}
198198
}
199199
case *plugin.Sync_Response_MigrateTable:
200-
if noMigrate {
201-
continue
202-
}
203200
sc, err := plugin.NewSchemaFromBytes(m.MigrateTable.Table)
204201
if err != nil {
205202
return err
206203
}
207204
tableName := tableNameFromSchema(sc)
208205
tables[tableName] = true
206+
if noMigrate {
207+
continue
208+
}
209209
for i := range destinationsPbClients {
210210
transformedSchema := destinationTransformers[i].TransformSchema(sc)
211211
transformedSchemaBytes, err := plugin.SchemaToBytes(transformedSchema)

0 commit comments

Comments
 (0)