(beam) branch master updated: Write append tables can be asynchronous (#39120)

[radek]

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

stankiewicz 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 0c51b0d288b Write append tables can be asynchronous (#39120)
0c51b0d288b is described below

commit 0c51b0d288b7c1f5eae24f0f4f9c2850d8d69d3b
Author: Radosław Stankiewicz <radosl...@google.com>
AuthorDate: Fri Jun 26 14:20:42 2026 +0200

    Write append tables can be asynchronous (#39120)
---
 .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',