(beam) branch master updated: Fix flaky BigQuery persistent retry test (#39539)

[shunping]

This is an automated email from the ASF dual-hosted git repository.

shunping pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 08dc50a3b91 Fix flaky BigQuery persistent retry test (#39539)
08dc50a3b91 is described below

commit 08dc50a3b91cfc066a641a01275ec9a0475263f2
Author: Bruno Volpato <brunocvcu...@gmail.com>
AuthorDate: Wed Jul 29 11:45:29 2026 -0400

    Fix flaky BigQuery persistent retry test (#39539)
---
 sdks/python/apache_beam/io/gcp/bigquery_test.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/io/gcp/bigquery_test.py 
b/sdks/python/apache_beam/io/gcp/bigquery_test.py
index 234c99847a4..50d758c6a31 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_test.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_test.py
@@ -1524,8 +1524,10 @@ class 
BigQueryStreamingInsertsErrorHandling(unittest.TestCase):
     # Expecting 1 initial call plus maximum number of retries
     expected_call_count = 1 + bigquery_tools.MAX_RETRIES
 
+    # This relies on runner-specific mocking behavior which can be
+    # inconsistent on Prism.
     with self.assertRaises(Exception) as exc:
-      with beam.Pipeline() as p:
+      with beam.Pipeline('FnApiRunner') as p:
         _ = (
             p
             | beam.Create([{