Skip to content

Commit f1d749a

Browse files
committed
schemafeed: improve some tests
Release note: None
1 parent 2d47570 commit f1d749a

File tree

4 files changed

+7
-13
lines changed

4 files changed

+7
-13
lines changed

pkg/ccl/changefeedccl/schemafeed/BUILD.bazel

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,6 @@ go_test(
7272
"//pkg/sql/catalog",
7373
"//pkg/sql/catalog/descpb",
7474
"//pkg/sql/catalog/tabledesc",
75-
"//pkg/sql/pgwire",
7675
"//pkg/testutils",
7776
"//pkg/testutils/datapathutils",
7877
"//pkg/testutils/serverutils",

pkg/ccl/changefeedccl/schemafeed/schema_feed_test.go

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@ import (
2424
"github.com/cockroachdb/cockroach/pkg/sql/catalog"
2525
"github.com/cockroachdb/cockroach/pkg/sql/catalog/descpb"
2626
"github.com/cockroachdb/cockroach/pkg/sql/catalog/tabledesc"
27-
"github.com/cockroachdb/cockroach/pkg/sql/pgwire"
2827
"github.com/cockroachdb/cockroach/pkg/testutils"
2928
"github.com/cockroachdb/cockroach/pkg/testutils/serverutils"
3029
"github.com/cockroachdb/cockroach/pkg/testutils/sqlutils"
@@ -197,7 +196,7 @@ func TestFetchDescriptorVersionsCPULimiterPagination(t *testing.T) {
197196
ctx := context.Background()
198197
var numRequests int
199198
first := true
200-
s, db, _ := serverutils.StartServer(t, base.TestServerArgs{
199+
srv, db, _ := serverutils.StartServer(t, base.TestServerArgs{
201200
Knobs: base.TestingKnobs{Store: &kvserver.StoreTestingKnobs{
202201
TestingRequestFilter: func(ctx context.Context, request *kvpb.BatchRequest) *kvpb.Error {
203202
for _, ru := range request.Requests {
@@ -220,11 +219,9 @@ func TestFetchDescriptorVersionsCPULimiterPagination(t *testing.T) {
220219
},
221220
}},
222221
})
223-
defer s.Stopper().Stop(ctx)
222+
defer srv.Stopper().Stop(ctx)
223+
s := srv.ApplicationLayer()
224224
sqlServer := s.SQLServer().(*sql.Server)
225-
if len(s.TestTenants()) != 0 {
226-
sqlServer = s.TestTenants()[0].PGServer().(*pgwire.Server).SQLServer
227-
}
228225

229226
sqlDB := sqlutils.MakeSQLRunner(db)
230227
beforeCreate := hlc.Timestamp{WallTime: timeutil.Now().UnixNano()}

pkg/ccl/changefeedccl/schemafeed/table_event_filter_datadriven_test.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -64,12 +64,11 @@ func TestDataDriven(t *testing.T) {
6464
testData := datapathutils.TestDataPath(t, "")
6565
datadriven.Walk(t, testData, func(t *testing.T, path string) {
6666
ctx := context.Background()
67-
ts, sqlDB, _ := serverutils.StartServer(t, base.TestServerArgs{
68-
// TODO(ajwerner): Otherwise the test gets skipped due to some CCL warning.
69-
DefaultTestTenant: base.TODOTestTenantDisabled,
70-
})
67+
srv, sqlDB, _ := serverutils.StartServer(t, base.TestServerArgs{})
68+
defer srv.Stopper().Stop(ctx)
69+
ts := srv.ApplicationLayer()
70+
7171
tdb := sqlutils.MakeSQLRunner(sqlDB)
72-
defer ts.Stopper().Stop(ctx)
7372
ctx, cancel := ts.Stopper().WithCancelOnQuiesce(ctx)
7473
defer cancel()
7574
schemaFeeds := map[int]schemafeed.SchemaFeed{}

pkg/testutils/lint/lint_test.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2230,7 +2230,6 @@ func TestLint(t *testing.T) {
22302230
":!ccl/changefeedccl/helpers_test.go",
22312231
":!ccl/changefeedccl/parquet_test.go",
22322232
":!ccl/changefeedccl/scheduled_changefeed_test.go",
2233-
":!ccl/changefeedccl/schemafeed/table_event_filter_datadriven_test.go",
22342233
":!ccl/importerccl/ccl_test.go",
22352234
":!ccl/kvccl/kvfollowerreadsccl/boundedstaleness_test.go",
22362235
":!ccl/kvccl/kvfollowerreadsccl/followerreads_test.go",

0 commit comments

Comments
 (0)