tvalentyn opened a new issue, #39526:
URL: https://github.com/apache/beam/issues/39526
### What happened?
```
2026-07-28T05:15:28.3582419Z =================================== FAILURES
===================================
2026-07-28T05:15:28.3592023Z _
BigQueryStreamingInsertsErrorHandling.test_insert_rows_json_persistent_retriable_exception_1
_
2026-07-28T05:15:28.3596426Z [gw3] linux -- Python 3.10.20
/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/bin/python
2026-07-28T05:15:28.3598686Z
2026-07-28T05:15:28.3600716Z a =
(<apache_beam.io.gcp.bigquery_test.BigQueryStreamingInsertsErrorHandling
testMethod=test_insert_rows_json_persistent_retriable_exception_1>,)
2026-07-28T05:15:28.3602935Z kw = {}
2026-07-28T05:15:28.3603427Z
2026-07-28T05:15:28.3603994Z @wraps(func)
2026-07-28T05:15:28.3604883Z def standalone_func(*a, **kw):
2026-07-28T05:15:28.3606976Z > return func(*(a + p.args), **p.kwargs,
**kw)
2026-07-28T05:15:28.3620551Z
2026-07-28T05:15:28.3631125Z
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/parameterized/parameterized.py:620:
2026-07-28T05:15:28.3633054Z _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
2026-07-28T05:15:28.3634785Z
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py:1468:
in patched
2026-07-28T05:15:28.3636624Z return func(*newargs, **newkeywargs)
2026-07-28T05:15:28.3638656Z
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/parameterized/parameterized.py:93:
in dummy_func
2026-07-28T05:15:28.3674178Z return orgfunc(*args, **kwargs)
2026-07-28T05:15:28.3675879Z
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py:1468:
in patched
2026-07-28T05:15:28.3678203Z return func(*newargs, **newkeywargs)
2026-07-28T05:15:28.3680775Z
target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_test.py:1546:
in test_insert_rows_json_persistent_retriable_exception
2026-07-28T05:15:28.3683199Z self.assertEqual(expected_call_count,
mock_send.call_count)
2026-07-28T05:15:28.3707437Z E AssertionError: 4 != 8
2026-07-28T05:15:28.3708673Z ----------------------------- Captured stderr
call -----------------------------
2026-07-28T05:15:28.3710294Z Traceback (most recent call last):
2026-07-28T05:15:28.3923378Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 310, in wrapper
2026-07-28T05:15:28.3926669Z sleep_interval = next(retry_intervals)
2026-07-28T05:15:28.3927708Z StopIteration
2026-07-28T05:15:28.3928174Z
2026-07-28T05:15:28.3928849Z During handling of the above exception, another
exception occurred:
2026-07-28T05:15:28.4016927Z
2026-07-28T05:15:28.4017776Z Traceback (most recent call last):
2026-07-28T05:15:28.4019865Z File "apache_beam/runners/common.py", line
1569, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.4021411Z bundle_method()
2026-07-28T05:15:28.4023088Z File "apache_beam/runners/common.py", line
618, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.4024669Z def invoke_finish_bundle(self):
2026-07-28T05:15:28.4026463Z File "apache_beam/runners/common.py", line
624, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.4028118Z
self.signature.finish_bundle_method.method_value())
2026-07-28T05:15:28.4062780Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1718, in finish_bundle
2026-07-28T05:15:28.4066388Z return self._flush_all_batches()
2026-07-28T05:15:28.4096329Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1726, in _flush_all_batches
2026-07-28T05:15:28.4123006Z *[
2026-07-28T05:15:28.4126082Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1727, in <listcomp>
2026-07-28T05:15:28.4129796Z self._flush_batch(destination)
2026-07-28T05:15:28.4133701Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1756, in _flush_batch
2026-07-28T05:15:28.4137274Z passed, errors =
self.bigquery_wrapper.insert_rows(
2026-07-28T05:15:28.4191519Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1327, in insert_rows
2026-07-28T05:15:28.4194884Z result, errors = self._insert_all_rows(
2026-07-28T05:15:28.4198196Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 313, in wrapper
2026-07-28T05:15:28.4217531Z raise exn.with_traceback(exn_traceback)
2026-07-28T05:15:28.4241732Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.4245826Z return fun(*args, **kwargs)
2026-07-28T05:15:28.4249189Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.4252846Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.4255822Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.4258716Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4273485Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.4276612Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4280033Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.4294554Z raise effect
2026-07-28T05:15:28.4297558Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.4311304Z return fun(*args, **kwargs)
2026-07-28T05:15:28.4314798Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.4318446Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.4327632Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.4334311Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4363012Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.4366216Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4369856Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.4372957Z raise effect
2026-07-28T05:15:28.4376442Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.4391640Z return fun(*args, **kwargs)
2026-07-28T05:15:28.4395033Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.4435111Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.4438374Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.4441399Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4444800Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.4448062Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4451926Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.4459950Z raise effect
2026-07-28T05:15:28.4462803Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.4477204Z return fun(*args, **kwargs)
2026-07-28T05:15:28.4481064Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.4484306Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.4498615Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.4502093Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4505188Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.4508397Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4524424Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.4527491Z raise effect
2026-07-28T05:15:28.4528512Z requests.exceptions.Timeout: some timeout error
2026-07-28T05:15:28.4529380Z
2026-07-28T05:15:28.4550490Z During handling of the above exception, another
exception occurred:
2026-07-28T05:15:28.4551691Z
2026-07-28T05:15:28.4552179Z Traceback (most recent call last):
2026-07-28T05:15:28.4555490Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 310, in _execute
2026-07-28T05:15:28.4558763Z response = task()
2026-07-28T05:15:28.4593070Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 384, in <lambda>
2026-07-28T05:15:28.4596959Z lambda:
self.create_worker().do_instruction(request), request)
2026-07-28T05:15:28.4600849Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 671, in do_instruction
2026-07-28T05:15:28.4604558Z return getattr(self, request_type)(
2026-07-28T05:15:28.4608075Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 709, in process_bundle
2026-07-28T05:15:28.4656341Z
bundle_processor.process_bundle(instruction_id))
2026-07-28T05:15:28.4660330Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1318, in process_bundle
2026-07-28T05:15:28.4697628Z op.finish()
2026-07-28T05:15:28.4700027Z File
"apache_beam/runners/worker/operations.py", line 988, in
apache_beam.runners.worker.operations.DoOperation.finish
2026-07-28T05:15:28.4702132Z def finish(self):
2026-07-28T05:15:28.4704010Z File
"apache_beam/runners/worker/operations.py", line 991, in
apache_beam.runners.worker.operations.DoOperation.finish
2026-07-28T05:15:28.4705890Z with self.scoped_finish_state:
2026-07-28T05:15:28.4740265Z File
"apache_beam/runners/worker/operations.py", line 992, in
apache_beam.runners.worker.operations.DoOperation.finish
2026-07-28T05:15:28.4742827Z self.dofn_runner.finish()
2026-07-28T05:15:28.4744833Z File "apache_beam/runners/common.py", line
1590, in apache_beam.runners.common.DoFnRunner.finish
2026-07-28T05:15:28.4779697Z
self._invoke_bundle_method(self.do_fn_invoker.invoke_finish_bundle)
2026-07-28T05:15:28.4782458Z File "apache_beam/runners/common.py", line
1571, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.4785031Z self._reraise_augmented(exn)
2026-07-28T05:15:28.4786905Z File "apache_beam/runners/common.py", line
1623, in apache_beam.runners.common.DoFnRunner._reraise_augmented
2026-07-28T05:15:28.4788387Z raise new_exn
2026-07-28T05:15:28.4804862Z File "apache_beam/runners/common.py", line
1569, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.4807206Z bundle_method()
2026-07-28T05:15:28.4809006Z File "apache_beam/runners/common.py", line
618, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.4811683Z def invoke_finish_bundle(self):
2026-07-28T05:15:28.4813803Z File "apache_beam/runners/common.py", line
624, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.4816021Z
self.signature.finish_bundle_method.method_value())
2026-07-28T05:15:28.4819474Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1718, in finish_bundle
2026-07-28T05:15:28.4843776Z return self._flush_all_batches()
2026-07-28T05:15:28.4847256Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1726, in _flush_all_batches
2026-07-28T05:15:28.4850643Z *[
2026-07-28T05:15:28.4864958Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1727, in <listcomp>
2026-07-28T05:15:28.4868412Z self._flush_batch(destination)
2026-07-28T05:15:28.4871793Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1756, in _flush_batch
2026-07-28T05:15:28.4897778Z passed, errors =
self.bigquery_wrapper.insert_rows(
2026-07-28T05:15:28.4901625Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1327, in insert_rows
2026-07-28T05:15:28.4905689Z result, errors = self._insert_all_rows(
2026-07-28T05:15:28.4920729Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 313, in wrapper
2026-07-28T05:15:28.4925031Z raise exn.with_traceback(exn_traceback)
2026-07-28T05:15:28.4928250Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.4942668Z return fun(*args, **kwargs)
2026-07-28T05:15:28.4946137Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.4949475Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.4973553Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.4977262Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4990823Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.4994532Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.4997790Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5015364Z raise effect
2026-07-28T05:15:28.5018394Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5021559Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5031998Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5047235Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5057819Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5060727Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5063966Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5078401Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5081918Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5085094Z raise effect
2026-07-28T05:15:28.5087963Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5102691Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5106134Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5130586Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5134785Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5137861Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5141757Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5144952Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5147841Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5151062Z raise effect
2026-07-28T05:15:28.5154166Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5157136Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5191404Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5195981Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5199139Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5202834Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5206046Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5209166Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5212670Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5216078Z raise effect
2026-07-28T05:15:28.5218151Z requests.exceptions.Timeout: some timeout error
[while running
'WriteToBigQuery/_StreamToBigQuery/StreamInsertRows/ParDo(BigQueryWriteFn)']
2026-07-28T05:15:28.5225956Z
2026-07-28T05:15:28.5226453Z Traceback (most recent call last):
2026-07-28T05:15:28.5229781Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 310, in wrapper
2026-07-28T05:15:28.5233760Z sleep_interval = next(retry_intervals)
2026-07-28T05:15:28.5234754Z StopIteration
2026-07-28T05:15:28.5235251Z
2026-07-28T05:15:28.5236365Z During handling of the above exception, another
exception occurred:
2026-07-28T05:15:28.5237419Z
2026-07-28T05:15:28.5237915Z Traceback (most recent call last):
2026-07-28T05:15:28.5240076Z File "apache_beam/runners/common.py", line
1569, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.5241995Z bundle_method()
2026-07-28T05:15:28.5243872Z File "apache_beam/runners/common.py", line
618, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.5245644Z def invoke_finish_bundle(self):
2026-07-28T05:15:28.5259180Z File "apache_beam/runners/common.py", line
624, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.5261513Z
self.signature.finish_bundle_method.method_value())
2026-07-28T05:15:28.5265193Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1718, in finish_bundle
2026-07-28T05:15:28.5279878Z return self._flush_all_batches()
2026-07-28T05:15:28.5283945Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1726, in _flush_all_batches
2026-07-28T05:15:28.5287222Z *[
2026-07-28T05:15:28.5290773Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1727, in <listcomp>
2026-07-28T05:15:28.5293928Z self._flush_batch(destination)
2026-07-28T05:15:28.5297121Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1756, in _flush_batch
2026-07-28T05:15:28.5312286Z passed, errors =
self.bigquery_wrapper.insert_rows(
2026-07-28T05:15:28.5315895Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1327, in insert_rows
2026-07-28T05:15:28.5330406Z result, errors = self._insert_all_rows(
2026-07-28T05:15:28.5334453Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 313, in wrapper
2026-07-28T05:15:28.5337320Z raise exn.with_traceback(exn_traceback)
2026-07-28T05:15:28.5361294Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5365568Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5368774Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5372357Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5376058Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5378933Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5386692Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5389769Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5392794Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5401611Z raise effect
2026-07-28T05:15:28.5404582Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5408092Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5411016Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5414491Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5428974Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5432230Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5436531Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5440723Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5444043Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5447135Z raise effect
2026-07-28T05:15:28.5461576Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5464809Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5468139Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5476520Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5480188Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5493873Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5496789Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5500088Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5503967Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5507010Z raise effect
2026-07-28T05:15:28.5509789Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5512846Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5528179Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5531422Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5535498Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5538632Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5541769Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5545458Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5548708Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5551753Z raise effect
2026-07-28T05:15:28.5553574Z File "apache_beam/runners/common.py", line
1569, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.5566891Z bundle_method()
2026-07-28T05:15:28.5568962Z File "apache_beam/runners/common.py", line
618, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.5571064Z def invoke_finish_bundle(self):
2026-07-28T05:15:28.5572948Z File "apache_beam/runners/common.py", line
624, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.5575315Z
self.signature.finish_bundle_method.method_value())
2026-07-28T05:15:28.5592553Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1718, in finish_bundle
2026-07-28T05:15:28.5595727Z return self._flush_all_batches()
2026-07-28T05:15:28.5599013Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1726, in _flush_all_batches
2026-07-28T05:15:28.5602475Z *[
2026-07-28T05:15:28.5605085Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1727, in <listcomp>
2026-07-28T05:15:28.5608057Z self._flush_batch(destination)
2026-07-28T05:15:28.5620312Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1756, in _flush_batch
2026-07-28T05:15:28.5625033Z passed, errors =
self.bigquery_wrapper.insert_rows(
2026-07-28T05:15:28.5628391Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1327, in insert_rows
2026-07-28T05:15:28.5631936Z result, errors = self._insert_all_rows(
2026-07-28T05:15:28.5636230Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 313, in wrapper
2026-07-28T05:15:28.5639180Z raise exn.with_traceback(exn_traceback)
2026-07-28T05:15:28.5642452Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5652242Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5655658Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5664494Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5668096Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5671027Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5678898Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5682059Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5685365Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5700191Z raise effect
2026-07-28T05:15:28.5702886Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5706146Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5709984Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5714104Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5717943Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5737506Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5740027Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5742439Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5745281Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5747619Z raise effect
2026-07-28T05:15:28.5750938Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5753430Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5756054Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5759684Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5762409Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5765102Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5767410Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5790572Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5794194Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5797256Z raise effect
2026-07-28T05:15:28.5800216Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5802533Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5804988Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5807366Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5810322Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5812841Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5815226Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.5817497Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5820118Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.5823077Z raise effect
2026-07-28T05:15:28.5824059Z requests.exceptions.Timeout: some timeout error
2026-07-28T05:15:28.5824879Z
2026-07-28T05:15:28.5825606Z During handling of the above exception, another
exception occurred:
2026-07-28T05:15:28.5826688Z
2026-07-28T05:15:28.5827124Z Traceback (most recent call last):
2026-07-28T05:15:28.5831975Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 310, in _execute
2026-07-28T05:15:28.5835472Z response = task()
2026-07-28T05:15:28.5838616Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 384, in <lambda>
2026-07-28T05:15:28.5853366Z lambda:
self.create_worker().do_instruction(request), request)
2026-07-28T05:15:28.5857109Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 671, in do_instruction
2026-07-28T05:15:28.5861034Z return getattr(self, request_type)(
2026-07-28T05:15:28.5863969Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/sdk_worker.py",
line 709, in process_bundle
2026-07-28T05:15:28.5867614Z
bundle_processor.process_bundle(instruction_id))
2026-07-28T05:15:28.5870656Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/runners/worker/bundle_processor.py",
line 1318, in process_bundle
2026-07-28T05:15:28.5882857Z op.finish()
2026-07-28T05:15:28.5884747Z File
"apache_beam/runners/worker/operations.py", line 988, in
apache_beam.runners.worker.operations.DoOperation.finish
2026-07-28T05:15:28.5886433Z def finish(self):
2026-07-28T05:15:28.5887903Z File
"apache_beam/runners/worker/operations.py", line 991, in
apache_beam.runners.worker.operations.DoOperation.finish
2026-07-28T05:15:28.5889855Z with self.scoped_finish_state:
2026-07-28T05:15:28.5891470Z File
"apache_beam/runners/worker/operations.py", line 992, in
apache_beam.runners.worker.operations.DoOperation.finish
2026-07-28T05:15:28.5893820Z self.dofn_runner.finish()
2026-07-28T05:15:28.5895457Z File "apache_beam/runners/common.py", line
1590, in apache_beam.runners.common.DoFnRunner.finish
2026-07-28T05:15:28.5897531Z
self._invoke_bundle_method(self.do_fn_invoker.invoke_finish_bundle)
2026-07-28T05:15:28.5899993Z File "apache_beam/runners/common.py", line
1571, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.5901836Z self._reraise_augmented(exn)
2026-07-28T05:15:28.5915252Z File "apache_beam/runners/common.py", line
1623, in apache_beam.runners.common.DoFnRunner._reraise_augmented
2026-07-28T05:15:28.5916895Z raise new_exn
2026-07-28T05:15:28.5918358Z File "apache_beam/runners/common.py", line
1569, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.5920018Z bundle_method()
2026-07-28T05:15:28.5921620Z File "apache_beam/runners/common.py", line
618, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.5923259Z def invoke_finish_bundle(self):
2026-07-28T05:15:28.5924898Z File "apache_beam/runners/common.py", line
624, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.5927100Z
self.signature.finish_bundle_method.method_value())
2026-07-28T05:15:28.5929808Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1718, in finish_bundle
2026-07-28T05:15:28.5932581Z return self._flush_all_batches()
2026-07-28T05:15:28.5936493Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1726, in _flush_all_batches
2026-07-28T05:15:28.5939997Z *[
2026-07-28T05:15:28.5943725Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1727, in <listcomp>
2026-07-28T05:15:28.5947475Z self._flush_batch(destination)
2026-07-28T05:15:28.5951394Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1756, in _flush_batch
2026-07-28T05:15:28.5961940Z passed, errors =
self.bigquery_wrapper.insert_rows(
2026-07-28T05:15:28.5965765Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1327, in insert_rows
2026-07-28T05:15:28.5975756Z result, errors = self._insert_all_rows(
2026-07-28T05:15:28.5978432Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 313, in wrapper
2026-07-28T05:15:28.5982275Z raise exn.with_traceback(exn_traceback)
2026-07-28T05:15:28.5984703Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.5986918Z return fun(*args, **kwargs)
2026-07-28T05:15:28.5989293Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.5992604Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.5995055Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.5997208Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.5999384Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6013625Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6016697Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6018928Z raise effect
2026-07-28T05:15:28.6021177Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6024454Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6027430Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6030165Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6032406Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6035319Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6037558Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6040176Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6044095Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6052217Z raise effect
2026-07-28T05:15:28.6054585Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6057561Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6061385Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6064835Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6079109Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6081782Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6149138Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6161677Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6165970Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6168970Z raise effect
2026-07-28T05:15:28.6172344Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6176031Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6179190Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6182014Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6184384Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6198817Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6201760Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6204225Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6206656Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6208934Z raise effect
2026-07-28T05:15:28.6210935Z File "apache_beam/runners/common.py", line
1569, in apache_beam.runners.common.DoFnRunner._invoke_bundle_method
2026-07-28T05:15:28.6212577Z bundle_method()
2026-07-28T05:15:28.6214363Z File "apache_beam/runners/common.py", line
618, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.6215927Z def invoke_finish_bundle(self):
2026-07-28T05:15:28.6217804Z File "apache_beam/runners/common.py", line
624, in apache_beam.runners.common.DoFnInvoker.invoke_finish_bundle
2026-07-28T05:15:28.6219954Z
self.signature.finish_bundle_method.method_value())
2026-07-28T05:15:28.6223685Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1718, in finish_bundle
2026-07-28T05:15:28.6227563Z return self._flush_all_batches()
2026-07-28T05:15:28.6230996Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1726, in _flush_all_batches
2026-07-28T05:15:28.6234433Z *[
2026-07-28T05:15:28.6237885Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1727, in <listcomp>
2026-07-28T05:15:28.6240881Z self._flush_batch(destination)
2026-07-28T05:15:28.6245034Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery.py",
line 1756, in _flush_batch
2026-07-28T05:15:28.6248086Z passed, errors =
self.bigquery_wrapper.insert_rows(
2026-07-28T05:15:28.6251500Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 1327, in insert_rows
2026-07-28T05:15:28.6255596Z result, errors = self._insert_all_rows(
2026-07-28T05:15:28.6259115Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 313, in wrapper
2026-07-28T05:15:28.6262538Z raise exn.with_traceback(exn_traceback)
2026-07-28T05:15:28.6266115Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6269210Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6272106Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6275246Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6277437Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6280080Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6282883Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6286571Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6290006Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6292857Z raise effect
2026-07-28T05:15:28.6295261Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6298191Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6301204Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6304599Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6307871Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6312921Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6316125Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6318768Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6321482Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6324522Z raise effect
2026-07-28T05:15:28.6327311Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6330447Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6333491Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6336311Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6339264Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6341959Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6344883Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6347517Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6351213Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6355055Z raise effect
2026-07-28T05:15:28.6357708Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/utils/retry.py",
line 300, in wrapper
2026-07-28T05:15:28.6360388Z return fun(*args, **kwargs)
2026-07-28T05:15:28.6363730Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/apache_beam/io/gcp/bigquery_tools.py",
line 762, in _insert_all_rows
2026-07-28T05:15:28.6367465Z errors =
self.gcp_bq_client.insert_rows_json(
2026-07-28T05:15:28.6370362Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1190, in __call__
2026-07-28T05:15:28.6373246Z return _mock_self._mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6376696Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1194, in _mock_call
2026-07-28T05:15:28.6379947Z return _mock_self._execute_mock_call(*args,
**kwargs)
2026-07-28T05:15:28.6382957Z File
"/runner/_work/beam/beam/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cloud/py310-cloud/lib/python3.10/site-packages/mock/mock.py",
line 1251, in _execute_mock_call
2026-07-28T05:15:28.6386055Z raise effect
2026-07-28T05:15:28.6388597Z requests.exceptions.Timeout: some timeout error
[while running
'WriteToBigQuery/_StreamToBigQuery/StreamInsertRows/ParDo(BigQueryWriteFn)']
2026-07-28T05:15:28.6390665Z
```
### Issue Failure
Failure: Test is flaky
### Issue Priority
Priority: 1 (unhealthy code / failing or flaky postcommit so we cannot be
sure the product is healthy)
### Issue Components
- [ ] Component: Python SDK
- [ ] Component: Java SDK
- [ ] Component: Go SDK
- [ ] Component: Typescript SDK
- [ ] Component: IO connector
- [ ] Component: Beam YAML
- [ ] Component: Beam examples
- [ ] Component: Beam playground
- [ ] Component: Beam katas
- [ ] Component: Website
- [ ] Component: Infrastructure
- [ ] Component: Spark Runner
- [ ] Component: Flink Runner
- [ ] Component: Prism Runner
- [ ] Component: Twister2 Runner
- [ ] Component: Hazelcast Jet Runner
- [ ] Component: Google Cloud Dataflow Runner
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
