(beam) branch oss-image-classification updated: Fix WriteToBigQuery

[vt...@apache.org]

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 <vi...@akvelon.com>
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