We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 65a8750 commit de6c69eCopy full SHA for de6c69e
1 file changed
internal/rows/arrowbased/batchloader_test.go
@@ -356,13 +356,18 @@ func TestCloudFetchSchemaOverride(t *testing.T) {
356
correctSchema := arrow.NewSchema(correctFields, nil)
357
var schemaBuf bytes.Buffer
358
schemaWriter := ipc.NewWriter(&schemaBuf, ipc.WithSchema(correctSchema))
359
- schemaWriter.Close()
+ if err := schemaWriter.Close(); err != nil {
360
+ t.Fatal(err)
361
+ }
362
correctSchemaBytes := schemaBuf.Bytes()
363
364
// Serve stale IPC data via mock HTTP
365
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
366
w.WriteHeader(http.StatusOK)
- w.Write(staleIPCBytes)
367
+ _, err := w.Write(staleIPCBytes)
368
+ if err != nil {
369
+ panic(err)
370
371
}))
372
defer server.Close()
373
0 commit comments