Skip to content

Commit 4023176

Browse files
general-kroll-4-lifegeneral-kroll-4-life
committed
- Repaired tests.
1 parent 064f21d commit 4023176

10 files changed

+32
-32
lines changed

‎internal/stackql/driver/aggregation_compute_disks_integration_test.go‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ func TestSelectComputeDisksOrderByCrtTmstpAsc(t *testing.T) {
3535
}
3636

3737
testSubject := func(t *testing.T, outFile *bufio.Writer) {
38-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
38+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
3939
handlerCtx.SetOutfile(os.Stdout)
4040
handlerCtx.SetOutErrFile(os.Stderr)
4141
if err != nil {
@@ -76,7 +76,7 @@ func TestSelectComputeDisksAggOrderBySizeAsc(t *testing.T) {
7676
}
7777

7878
testSubject := func(t *testing.T, outFile *bufio.Writer) {
79-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
79+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
8080
handlerCtx.SetOutfile(os.Stdout)
8181
handlerCtx.SetOutErrFile(os.Stderr)
8282
if err != nil {
@@ -117,7 +117,7 @@ func TestSelectComputeDisksAggOrderBySizeDesc(t *testing.T) {
117117
}
118118

119119
testSubject := func(t *testing.T, outFile *bufio.Writer) {
120-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
120+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
121121
handlerCtx.SetOutfile(os.Stdout)
122122
handlerCtx.SetOutErrFile(os.Stderr)
123123
if err != nil {
@@ -158,7 +158,7 @@ func TestSelectComputeDisksAggTotalSize(t *testing.T) {
158158
}
159159

160160
testSubject := func(t *testing.T, outFile *bufio.Writer) {
161-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
161+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
162162
handlerCtx.SetOutfile(os.Stdout)
163163
handlerCtx.SetOutErrFile(os.Stderr)
164164
if err != nil {
@@ -199,7 +199,7 @@ func TestSelectComputeDisksAggTotalString(t *testing.T) {
199199
}
200200

201201
testSubject := func(t *testing.T, outFile *bufio.Writer) {
202-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
202+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
203203
handlerCtx.SetOutfile(os.Stdout)
204204
handlerCtx.SetOutErrFile(os.Stderr)
205205
if err != nil {

‎internal/stackql/driver/aggregation_container_subnetworks_integration_test.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ func TestSimpleAggGoogleContainerSubnetworksGroupedAllowedDriverOutputAsc(t *tes
2727
}
2828

2929
testSubject := func(t *testing.T, outFile *bufio.Writer) {
30-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
30+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
3131
handlerCtx.SetOutfile(os.Stdout)
3232
handlerCtx.SetOutErrFile(os.Stderr)
3333
if err != nil {
@@ -68,7 +68,7 @@ func TestSimpleAggGoogleContainerSubnetworksGroupedAllowedDriverOutputDesc(t *te
6868
}
6969

7070
testSubject := func(t *testing.T, outFile *bufio.Writer) {
71-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
71+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
7272
handlerCtx.SetOutfile(os.Stdout)
7373
handlerCtx.SetOutErrFile(os.Stderr)
7474
if err != nil {

‎internal/stackql/driver/aggregation_paginated_compute_disks_integration_test.go‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ func TestSelectComputeDisksOrderByCrtTmstpAscPaginated(t *testing.T) {
2929
}
3030

3131
testSubject := func(t *testing.T, outFile *bufio.Writer) {
32-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
32+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
3333
handlerCtx.SetOutfile(os.Stdout)
3434
handlerCtx.SetOutErrFile(os.Stderr)
3535
if err != nil {
@@ -71,7 +71,7 @@ func TestSelectComputeDisksAggOrderBySizeAscPaginated(t *testing.T) {
7171
}
7272

7373
testSubject := func(t *testing.T, outFile *bufio.Writer) {
74-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
74+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
7575
handlerCtx.SetOutfile(os.Stdout)
7676
handlerCtx.SetOutErrFile(os.Stderr)
7777
if err != nil {
@@ -113,7 +113,7 @@ func TestSelectComputeDisksAggOrderBySizeDescPaginated(t *testing.T) {
113113
}
114114

115115
testSubject := func(t *testing.T, outFile *bufio.Writer) {
116-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
116+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
117117
handlerCtx.SetOutfile(os.Stdout)
118118
handlerCtx.SetOutErrFile(os.Stderr)
119119
if err != nil {
@@ -155,7 +155,7 @@ func TestSelectComputeDisksAggTotalSizePaginated(t *testing.T) {
155155
}
156156

157157
testSubject := func(t *testing.T, outFile *bufio.Writer) {
158-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
158+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
159159
handlerCtx.SetOutfile(os.Stdout)
160160
handlerCtx.SetOutErrFile(os.Stderr)
161161
if err != nil {
@@ -197,7 +197,7 @@ func TestSelectComputeDisksAggTotalStringPaginated(t *testing.T) {
197197
}
198198

199199
testSubject := func(t *testing.T, outFile *bufio.Writer) {
200-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
200+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
201201
handlerCtx.SetOutfile(os.Stdout)
202202
handlerCtx.SetOutErrFile(os.Stderr)
203203
if err != nil {

‎internal/stackql/driver/dependent_simple_integration_test.go‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ func TestSimpleInsertDependentGoogleComputeDiskAsync(t *testing.T) {
3838
if err != nil {
3939
t.Fatalf("Test failed: %v", err)
4040
}
41-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
41+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
4242
handlerCtx.SetOutfile(os.Stdout)
4343
handlerCtx.SetOutErrFile(os.Stderr)
4444
if err != nil {
@@ -81,7 +81,7 @@ func TestSimpleInsertDependentGoogleComputeDiskAsyncReversed(t *testing.T) {
8181
if err != nil {
8282
t.Fatalf("Test failed: %v", err)
8383
}
84-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
84+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
8585
handlerCtx.SetOutfile(os.Stdout)
8686
handlerCtx.SetOutErrFile(os.Stderr)
8787
if err != nil {
@@ -124,7 +124,7 @@ func TestSimpleInsertDependentGoogleBQDatasetAsync(t *testing.T) {
124124
if err != nil {
125125
t.Fatalf("Test failed: %v", err)
126126
}
127-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
127+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
128128
handlerCtx.SetOutfile(os.Stdout)
129129
handlerCtx.SetOutErrFile(os.Stderr)
130130
if err != nil {
@@ -167,7 +167,7 @@ func TestSimpleSelectExecDependentGoogleOrganizationsGetIamPolicy(t *testing.T)
167167
if err != nil {
168168
t.Fatalf("Test failed: %v", err)
169169
}
170-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
170+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
171171
handlerCtx.SetOutfile(os.Stdout)
172172
handlerCtx.SetOutErrFile(os.Stderr)
173173
if err != nil {

‎internal/stackql/driver/driver_integration_test.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ func TestSimpleSelectGoogleComputeInstanceDriverOutput(t *testing.T) {
7777
}
7878

7979
testSubject := func(t *testing.T, outFile *bufio.Writer) {
80-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
80+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
8181
handlerCtx.SetOutfile(os.Stdout)
8282
handlerCtx.SetOutErrFile(os.Stderr)
8383
if err != nil {
@@ -118,7 +118,7 @@ func TestSimpleSelectGoogleComputeInstanceDriverOutputRepeated(t *testing.T) {
118118
}
119119

120120
testSubject := func(t *testing.T, outFile *bufio.Writer) {
121-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
121+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
122122
handlerCtx.SetOutfile(os.Stdout)
123123
handlerCtx.SetOutErrFile(os.Stderr)
124124
if err != nil {
@@ -159,7 +159,7 @@ func TestSimpleSelectGoogleContainerSubnetworksAllowedDriverOutput(t *testing.T)
159159
}
160160

161161
testSubject := func(t *testing.T, outFile *bufio.Writer) {
162-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
162+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
163163
handlerCtx.SetOutfile(os.Stdout)
164164
handlerCtx.SetOutErrFile(os.Stderr)
165165
if err != nil {
@@ -200,7 +200,7 @@ func TestSimpleInsertGoogleComputeNetworkAsync(t *testing.T) {
200200
}
201201

202202
testSubject := func(t *testing.T, outFile *bufio.Writer) {
203-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
203+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
204204
handlerCtx.SetOutfile(os.Stdout)
205205
handlerCtx.SetOutErrFile(os.Stderr)
206206
if err != nil {
@@ -252,7 +252,7 @@ func TestK8sTheHardWayAsync(t *testing.T) {
252252
runtimeCtx.InfilePath = k8sthwRenderedFile
253253
runtimeCtx.CSVHeadersDisable = true
254254

255-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
255+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
256256
handlerCtx.SetOutfile(os.Stdout)
257257
handlerCtx.SetOutErrFile(os.Stderr)
258258
if err != nil {
@@ -306,7 +306,7 @@ func TestSimpleDryRunK8sTheHardWayDriver(t *testing.T) {
306306
t.Fatalf("Test failed: %v", err)
307307
}
308308

309-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
309+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
310310
handlerCtx.SetOutfile(os.Stdout)
311311
handlerCtx.SetOutErrFile(os.Stderr)
312312
if err != nil {

‎internal/stackql/driver/functions_integration_test.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ func TestSelectComputeDisksOrderByCrtTmstpAscPlusJsonExtract(t *testing.T) {
3131
}
3232

3333
testSubject := func(t *testing.T, outFile *bufio.Writer) {
34-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
34+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
3535
handlerCtx.SetOutfile(os.Stdout)
3636
handlerCtx.SetOutErrFile(os.Stderr)
3737
if err != nil {
@@ -72,7 +72,7 @@ func TestSelectComputeDisksOrderByCrtTmstpAscPlusCoalesceJsonExtract(t *testing.
7272
}
7373

7474
testSubject := func(t *testing.T, outFile *bufio.Writer) {
75-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
75+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
7676
handlerCtx.SetOutfile(os.Stdout)
7777
handlerCtx.SetOutErrFile(os.Stderr)
7878
if err != nil {
@@ -113,7 +113,7 @@ func TestSelectComputeDisksOrderByCrtTmstpAscPlusCoalesceJsonInstr(t *testing.T)
113113
}
114114

115115
testSubject := func(t *testing.T, outFile *bufio.Writer) {
116-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
116+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
117117
handlerCtx.SetOutfile(os.Stdout)
118118
handlerCtx.SetOutErrFile(os.Stderr)
119119
if err != nil {

‎internal/stackql/driver/okta_integration_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ func TestSimpleSelectOktaApplicationAppsDriverOutput(t *testing.T) {
8686
}
8787

8888
testSubject := func(t *testing.T, outFile *bufio.Writer) {
89-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
89+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
9090
handlerCtx.SetOutfile(os.Stdout)
9191
handlerCtx.SetOutErrFile(os.Stderr)
9292
if err != nil {

‎internal/stackql/driver/routine_complex_integration_test.go‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ func TestUnionAllSelectComputeDisksOrderByCrtTmstpAscPlusCoalesceJsonExtract(t *
3131
}
3232

3333
testSubject := func(t *testing.T, outFile *bufio.Writer) {
34-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
34+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, strings.NewReader(""), lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
3535
handlerCtx.SetOutfile(os.Stdout)
3636
handlerCtx.SetOutErrFile(os.Stderr)
3737
if err != nil {

‎internal/stackql/driver/show_insert_integration_test.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ func TestSimpleShowInsertComputeAddressesRequired(t *testing.T) {
4040
t.Fatalf("Test failed: %v", err)
4141
}
4242

43-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
43+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
4444
handlerCtx.SetOutfile(os.Stdout)
4545
handlerCtx.SetOutErrFile(os.Stderr)
4646
if err != nil {
@@ -80,7 +80,7 @@ func TestSimpleShowInsertBiqueryDatasetsRequired(t *testing.T) {
8080
t.Fatalf("Test failed: %v", err)
8181
}
8282

83-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
83+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
8484
handlerCtx.SetOutfile(os.Stdout)
8585
handlerCtx.SetOutErrFile(os.Stderr)
8686
if err != nil {

‎internal/stackql/driver/show_various_integration_test.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ func TestSimpleShowResourcesFiltered(t *testing.T) {
4141
t.Fatalf("Test failed: %v", err)
4242
}
4343

44-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
44+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
4545
handlerCtx.SetOutfile(os.Stdout)
4646
handlerCtx.SetOutErrFile(os.Stderr)
4747
if err != nil {
@@ -82,7 +82,7 @@ func TestSimpleShowBQDatasets(t *testing.T) {
8282
t.Fatalf("Test failed: %v", err)
8383
}
8484

85-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
85+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
8686
handlerCtx.SetOutfile(os.Stdout)
8787
handlerCtx.SetOutErrFile(os.Stderr)
8888
if err != nil {
@@ -123,7 +123,7 @@ func TestSimpleShowGoogleStorageBuckets(t *testing.T) {
123123
t.Fatalf("Test failed: %v", err)
124124
}
125125

126-
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle)
126+
handlerCtx, err := entryutil.BuildHandlerContext(*runtimeCtx, rdr, lrucache.NewLRUCache(int64(runtimeCtx.QueryCacheSize)), inputBundle, true)
127127
handlerCtx.SetOutfile(os.Stdout)
128128
handlerCtx.SetOutErrFile(os.Stderr)
129129
if err != nil {

0 commit comments

Comments
 (0)