fix(deps): Use SDK 4.0.0 (#236)

cloudquery · Jul 12, 2023 · 29ceed7 · 29ceed7
1 parent 432098a
commit 29ceed7
Show file tree

Hide file tree

Showing 10 changed files with 30 additions and 21 deletions.
diff --git a/csv/testdata/TestWriteRead-default.csv b/csv/testdata/TestWriteRead-default.csv
diff --git a/csv/testdata/TestWriteRead-with_delimiter.csv b/csv/testdata/TestWriteRead-with_delimiter.csv
diff --git a/csv/testdata/TestWriteRead-with_delimiter_headers.csv b/csv/testdata/TestWriteRead-with_delimiter_headers.csv
diff --git a/csv/testdata/TestWriteRead-with_headers.csv b/csv/testdata/TestWriteRead-with_headers.csv
diff --git a/csv/write_read_test.go b/csv/write_read_test.go
@@ -39,7 +39,9 @@ func TestWriteRead(t *testing.T) {
 				StableUUID: uuid.MustParse("00000000-0000-0000-0000-000000000001"),
 				StableTime: time.Date(2021, 1, 2, 0, 0, 0, 0, time.UTC),
 			}
-			records := schema.GenTestData(table, opts)
+			tg := schema.NewTestDataGenerator()
+			records := tg.Generate(table, opts)
+
 			cl, err := NewClient(tc.options...)
 			if err != nil {
 				t.Fatal(err)
@@ -98,7 +100,8 @@ func BenchmarkWrite(b *testing.B) {
 		SyncTime:   syncTime,
 		MaxRows:    1000,
 	}
-	records := schema.GenTestData(table, opts)
+	tg := schema.NewTestDataGenerator()
+	records := tg.Generate(table, opts)
 
 	cl, err := NewClient()
 	if err != nil {

diff --git a/go.mod b/go.mod
@@ -5,7 +5,7 @@ go 1.19
 require (
 	github.com/apache/arrow/go/v13 v13.0.0-20230630125530-5a06b2ec2a8e
 	github.com/bradleyjkemp/cupaloy/v2 v2.8.0
-	github.com/cloudquery/plugin-sdk/v4 v4.2.0-rc1
+	github.com/cloudquery/plugin-sdk/v4 v4.0.0
 	github.com/goccy/go-json v0.10.2
 	github.com/google/uuid v1.3.0
 	github.com/stretchr/testify v1.8.4

diff --git a/go.sum b/go.sum
@@ -8,8 +8,8 @@ github.com/bradleyjkemp/cupaloy/v2 v2.8.0 h1:any4BmKE+jGIaMpnU8YgH/I2LPiLBufr6oM
 github.com/bradleyjkemp/cupaloy/v2 v2.8.0/go.mod h1:bm7JXdkRd4BHJk9HpwqAI8BoAY1lps46Enkdqw6aRX0=
 github.com/cloudquery/arrow/go/v13 v13.0.0-20230710001530-a2a76ebbb85f h1:Lskz0i/P0Ye+6Eg3+LiRO6O1MOzwAUnS+rpkX8NmluM=
 github.com/cloudquery/arrow/go/v13 v13.0.0-20230710001530-a2a76ebbb85f/go.mod h1:W69eByFNO0ZR30q1/7Sr9d83zcVZmF2MiP3fFYAWJOc=
-github.com/cloudquery/plugin-sdk/v4 v4.2.0-rc1 h1:sRjZ/Lb/yjLw92HzvgPiyVynbocbtaa13fEgS9MN/DQ=
-github.com/cloudquery/plugin-sdk/v4 v4.2.0-rc1/go.mod h1:gn2ANihFC5SUMPCcYnVD+Gt3Cgn8OeXJW2/0lRUoB68=
+github.com/cloudquery/plugin-sdk/v4 v4.0.0 h1:T5fEGLXFzKmPs1DGfvKxb69N+DtrjkqHFaBT3Zp+Tdg=
+github.com/cloudquery/plugin-sdk/v4 v4.0.0/go.mod h1:87grEi32vA95lVQ9nIPC3QWVs325nEgtZf/MeXgUcrw=
 github.com/coreos/go-systemd/v22 v22.5.0/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=

diff --git a/json/testdata/TestWriteRead.jsonl b/json/testdata/TestWriteRead.jsonl
diff --git a/json/write_read_test.go b/json/write_read_test.go
@@ -26,7 +26,9 @@ func TestWriteRead(t *testing.T) {
 		StableUUID: uuid.MustParse("00000000-0000-0000-0000-000000000001"),
 		StableTime: time.Date(2021, 1, 2, 0, 0, 0, 0, time.UTC),
 	}
-	records := schema.GenTestData(table, opts)
+	tg := schema.NewTestDataGenerator()
+	records := tg.Generate(table, opts)
+
 	cl, err := NewClient()
 	if err != nil {
 		t.Fatal(err)
@@ -83,7 +85,8 @@ func BenchmarkWrite(b *testing.B) {
 		SyncTime:   syncTime,
 		MaxRows:    1000,
 	}
-	records := schema.GenTestData(table, opts)
+	tg := schema.NewTestDataGenerator()
+	records := tg.Generate(table, opts)
 
 	cl, err := NewClient()
 	if err != nil {

diff --git a/parquet/write_read_test.go b/parquet/write_read_test.go
@@ -24,7 +24,9 @@ func TestWriteRead(t *testing.T) {
 		SyncTime:   syncTime,
 		MaxRows:    2,
 	}
-	records := schema.GenTestData(table, opts)
+	tg := schema.NewTestDataGenerator()
+	records := tg.Generate(table, opts)
+
 	writer := bufio.NewWriter(&b)
 	reader := bufio.NewReader(&b)
 
@@ -76,7 +78,8 @@ func BenchmarkWrite(b *testing.B) {
 		SyncTime:   syncTime,
 		MaxRows:    b.N,
 	}
-	records := schema.GenTestData(table, opts)
+	tg := schema.NewTestDataGenerator()
+	records := tg.Generate(table, opts)
 
 	cl, err := NewClient()
 	if err != nil {