Skip to content

Commit 0704777

Browse files
committed
use broad table
1 parent 878a0fd commit 0704777

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

plugins/destination/plugin_testing_migrate.go

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -245,14 +245,7 @@ func (*PluginTestSuite) destinationPluginTestMigrate(
245245

246246
t.Run("double_migration", func(t *testing.T) {
247247
tableName := "double_migration_" + tableUUIDSuffix()
248-
md := arrow.NewMetadata([]string{schema.MetadataTableName}, []string{tableName})
249-
table := arrow.NewSchema([]arrow.Field{
250-
schema.CqSourceNameField,
251-
schema.CqSyncTimeField,
252-
schema.CqIDField,
253-
{Name: "id", Type: types.ExtensionTypes.UUID, Nullable: true},
254-
{Name: "bool", Type: arrow.FixedWidthTypes.Boolean},
255-
}, &md)
248+
table := schema.CQSchemaToArrow(testdata.TestTable(tableName))
256249

257250
p := newPlugin()
258251
require.NoError(t, p.Init(ctx, logger, spec))

0 commit comments

Comments
 (0)