File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
packages/google-cloud-bigquery-storage/samples/pyarrow Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -188,7 +188,9 @@ def generate_write_requests(pyarrow_table):
188188 # Combine collected batches and yield request
189189 combined_table = pa .Table .from_batches (batches_in_request )
190190 request = gapic_types .AppendRowsRequest ()
191- request .arrow_rows .rows .serialized_record_batch = combined_table .serialize ().to_pybytes ()
191+ request .arrow_rows .rows .serialized_record_batch = (
192+ combined_table .serialize ().to_pybytes ()
193+ )
192194 yield request
193195
194196 # Reset for next request.
@@ -202,7 +204,9 @@ def generate_write_requests(pyarrow_table):
202204 if batches_in_request :
203205 combined_table = pa .Table .from_batches (batches_in_request )
204206 request = gapic_types .AppendRowsRequest ()
205- request .arrow_rows .rows .serialized_record_batch = combined_table .serialize ().to_pybytes ()
207+ request .arrow_rows .rows .serialized_record_batch = (
208+ combined_table .serialize ().to_pybytes ()
209+ )
206210 yield request
207211
208212
You can’t perform that action at this time.
0 commit comments