Write append tables can be asynchronous (#39120) (#39148)

stankiewicz · web-flow · commit eea560f39a9a · 2026-06-29T09:28:28.000-04:00
diff --git 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
@@ -607,7 +607,7 @@ def _determine_write_disposition(self, copy_to_reference) -> tuple[bool, str]:
         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',

Original file line number	Diff line number	Diff line change
`@@ -1,5 +1,5 @@`
`1`	`1`	`{`
`2`	`2`	`"comment": "Modify this file in a trivial way to cause this test suite to run.",`
`3`	`3`	`"pr": "37345",`
`4`		`- "modification": 51`
`5`		`-}`
	`4`	`+ "modification": 52`
	`5`	`+}`