This is an automated email from the ASF dual-hosted git repository.
vterentev pushed a commit to branch oss-image-classification
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/oss-image-classification by
this push:
new fc0b65bcaac Fix WriteToBigQuery
fc0b65bcaac is described below
commit fc0b65bcaacbf2b5c2bb683488079b9fb5514a19
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Fri Nov 7 12:23:05 2025 +0400
Fix WriteToBigQuery
---
.../apache_beam/examples/inference/pytorch_imagenet_rightfit.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/sdks/python/apache_beam/examples/inference/pytorch_imagenet_rightfit.py
b/sdks/python/apache_beam/examples/inference/pytorch_imagenet_rightfit.py
index 611a87551ff..e6415bc67fb 100644
--- a/sdks/python/apache_beam/examples/inference/pytorch_imagenet_rightfit.py
+++ b/sdks/python/apache_beam/examples/inference/pytorch_imagenet_rightfit.py
@@ -435,8 +435,8 @@ def run(argv=None, save_main_session=True,
test_pipeline=None) -> PipelineResult
schema='image_id:STRING, model_name:STRING, topk:STRING,
infer_ts_ms:INT64',
write_disposition=beam.io.BigQueryDisposition.WRITE_APPEND,
create_disposition=beam.io.BigQueryDisposition.CREATE_IF_NEEDED,
- method=beam.io.WriteToBigQuery.Method.STREAMING_INSERTS,
- with_insert_ids=True))
+ method=beam.io.WriteToBigQuery.Method.STREAMING_INSERTS)
+ )
result = pipeline.run()
result.wait_until_finish(duration=1800000) # 30 min
