From 7da292683b7b2e8953d8e1623bc52a6af6a4f7e1 Mon Sep 17 00:00:00 2001 From: Trevor Bergeron Date: Thu, 15 Jan 2026 20:13:29 +0000 Subject: [PATCH] fix: Throw if write api commit op has stream_errors --- bigframes/session/loader.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/bigframes/session/loader.py b/bigframes/session/loader.py index bf91637be4..9c18d727c8 100644 --- a/bigframes/session/loader.py +++ b/bigframes/session/loader.py @@ -540,7 +540,9 @@ def request_generator(): commit_request = bq_storage_types.BatchCommitWriteStreamsRequest( parent=parent, write_streams=stream_names ) - self._write_client.batch_commit_write_streams(commit_request) + response = self._write_client.batch_commit_write_streams(commit_request) + for error in response.stream_errors: + raise ValueError(f"Errors commiting stream {error}") result_table = bq_data.GbqTable.from_ref_and_schema( bq_table_ref, schema=bq_schema, cluster_cols=[offsets_col]