Skip to content

Commit 7abfef0

Browse files
fix: Throw if write api commit op has stream_errors (#2385)
1 parent 9c3bbc3 commit 7abfef0

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

bigframes/session/loader.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -540,7 +540,9 @@ def request_generator():
540540
commit_request = bq_storage_types.BatchCommitWriteStreamsRequest(
541541
parent=parent, write_streams=stream_names
542542
)
543-
self._write_client.batch_commit_write_streams(commit_request)
543+
response = self._write_client.batch_commit_write_streams(commit_request)
544+
for error in response.stream_errors:
545+
raise ValueError(f"Errors commiting stream {error}")
544546

545547
result_table = bq_data.GbqTable.from_ref_and_schema(
546548
bq_table_ref, schema=bq_schema, cluster_cols=[offsets_col]

0 commit comments

Comments
 (0)