diff --git a/runtime/drivers/bigquery/warehouse.go b/runtime/drivers/bigquery/warehouse.go index 89cc57e64022..b446f3ae8795 100644 --- a/runtime/drivers/bigquery/warehouse.go +++ b/runtime/drivers/bigquery/warehouse.go @@ -211,6 +211,7 @@ var _ drivers.FileIterator = &fileIterator{} // Close implements drivers.FileIterator. func (f *fileIterator) Close() error { + f.client.Close() return os.RemoveAll(f.tempDir) }