File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed
packages/bigframes/bigframes/session Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change 5252import pandas
5353import pyarrow as pa
5454from google .cloud import bigquery_storage_v1
55- from google .cloud .bigquery_storage_v1 import types as bq_storage_types , writer as bq_storage_writer
55+ from google .cloud .bigquery_storage_v1 import (
56+ types as bq_storage_types ,
57+ writer as bq_storage_writer ,
58+ )
5659
5760import bigframes ._tools
5861import bigframes ._tools .strings
@@ -520,7 +523,9 @@ def write_data(
520523 )
521524 serialized_schema = schema .serialize ().to_pybytes ()
522525
523- def stream_worker (work : Iterator [pa .RecordBatch ], max_outstanding : int = 5 ) -> str :
526+ def stream_worker (
527+ work : Iterator [pa .RecordBatch ], max_outstanding : int = 5
528+ ) -> str :
524529 requested_stream = bq_storage_types .WriteStream (
525530 type_ = bq_storage_types .WriteStream .Type .PENDING
526531 )
You can’t perform that action at this time.
0 commit comments