This repository was archived by the owner on Mar 6, 2026. It is now read-only.
File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 1616import datetime
1717import decimal
1818import functools
19+ import gc
1920import operator
2021import queue
2122from typing import Union
@@ -1886,7 +1887,6 @@ def fake_download_stream(
18861887 assert queue_used .maxsize == expected_maxsize
18871888
18881889
1889- '''
18901890@pytest .mark .skipif (isinstance (pyarrow , mock .Mock ), reason = "Requires `pyarrow`" )
18911891def test__download_table_bqstorage_shuts_down_workers (
18921892 monkeypatch ,
@@ -1897,6 +1897,7 @@ def test__download_table_bqstorage_shuts_down_workers(
18971897 Make sure that when the top-level iterator goes out of scope (is deleted),
18981898 the child threads are also stopped.
18991899 """
1900+ pytest .importorskip ("google.cloud.bigquery_storage_v1" )
19001901 from google .cloud .bigquery import dataset
19011902 from google .cloud .bigquery import table
19021903 import google .cloud .bigquery_storage_v1 .reader
@@ -2013,7 +2014,6 @@ def test_download_arrow_row_iterator_unknown_field_type(module_under_test):
20132014 col = result .columns [1 ]
20142015 assert type (col ) is pyarrow .lib .DoubleArray
20152016 assert col .to_pylist () == [2.2 , 22.22 , 222.222 ]
2016- '''
20172017
20182018
20192019@pytest .mark .skipif (isinstance (pyarrow , mock .Mock ), reason = "Requires `pyarrow`" )
You can’t perform that action at this time.
0 commit comments