This is an automated email from the ASF dual-hosted git repository.
damccorm 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 7ecbb2a7037 Pin a mocking test to DirectRunner (#35883)
7ecbb2a7037 is described below
commit 7ecbb2a7037ecea0aded933d3030f3a451c5c679
Author: Danny McCormick <[email protected]>
AuthorDate: Fri Aug 15 16:34:53 2025 -0400
Pin a mocking test to DirectRunner (#35883)
* Pin a mocking test to DirectRunner
* Update bigquery_test.py
---
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 b038f38bd5a..dcb85d60f87 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_test.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_test.py
@@ -1567,7 +1567,9 @@ class
BigQueryStreamingInsertsErrorHandling(unittest.TestCase):
exception_type(error_message), exception_type(error_message), []
]
- with beam.Pipeline() as p:
+ # This relies on DirectRunner-specific mocking behavior which can be
+ # inconsistent on Prism
+ with beam.Pipeline('FnApiRunner') as p:
_ = (
p
| beam.Create([{
