Skip to content

Commit e60c8a4

Browse files
committed
fix: Destination migration testing using incorrect mode
1 parent 6c0d0b3 commit e60c8a4

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

plugins/destination/plugin_testing.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,7 @@ func PluginTestSuiteRunner(t *testing.T, newPlugin NewPluginFunc, destSpec specs
146146
t.Skip("skipping " + t.Name())
147147
}
148148
destSpec.WriteMode = specs.WriteModeOverwrite
149+
destSpec.MigrateMode = specs.MigrateModeSafe
149150
destSpec.Name = "test_migrate_overwrite"
150151
suite.destinationPluginTestMigrate(ctx, t, newPlugin, logger, destSpec, tests.MigrateStrategyOverwrite)
151152
})
@@ -182,6 +183,7 @@ func PluginTestSuiteRunner(t *testing.T, newPlugin NewPluginFunc, destSpec specs
182183
t.Skip("skipping " + t.Name())
183184
}
184185
destSpec.WriteMode = specs.WriteModeAppend
186+
destSpec.MigrateMode = specs.MigrateModeSafe
185187
destSpec.Name = "test_migrate_append"
186188
suite.destinationPluginTestMigrate(ctx, t, newPlugin, logger, destSpec, tests.MigrateStrategyAppend)
187189
})

0 commit comments

Comments
 (0)