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

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


The following commit(s) were added to refs/heads/release-2.75 by this push:
     new eea560f39a9 Write append tables can be asynchronous (#39120) (#39148)
eea560f39a9 is described below

commit eea560f39a9af203e7df3dc61cca8038edb50b39
Author: RadosÅ‚aw Stankiewicz <[email protected]>
AuthorDate: Mon Jun 29 15:28:28 2026 +0200

    Write append tables can be asynchronous (#39120) (#39148)
---
 .github/trigger_files/beam_PostCommit_Python.json     | 4 ++--
 sdks/python/apache_beam/io/gcp/bigquery_file_loads.py | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/.github/trigger_files/beam_PostCommit_Python.json 
b/.github/trigger_files/beam_PostCommit_Python.json
index 98bf4bf9500..2e255c8f3cf 100644
--- a/.github/trigger_files/beam_PostCommit_Python.json
+++ b/.github/trigger_files/beam_PostCommit_Python.json
@@ -1,5 +1,5 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to 
run.",
   "pr": "37345",
-  "modification": 51
-} 
+  "modification": 52
+}
diff --git a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py 
b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
index 4e45d0324ee..8857b5fb433 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py
@@ -607,7 +607,7 @@ class TriggerCopyJobs(beam.DoFn):
         copy_to_reference.tableId)
     if full_table_ref not in self._observed_tables:
       write_disposition = self.write_disposition
-      wait_for_job = True
+      wait_for_job = write_disposition != 'WRITE_APPEND'
       self._observed_tables.add(full_table_ref)
       Lineage.sinks().add(
           'bigquery',

Reply via email to