Skip to content

Commit 8a23f3b

Browse files
committed
format
1 parent 26c6003 commit 8a23f3b

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

sdks/python/apache_beam/io/gcp/bigquery_file_loads.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -607,7 +607,8 @@ def _determine_write_disposition(self, copy_to_reference) -> tuple[bool, str]:
607607
copy_to_reference.tableId)
608608
if full_table_ref not in self._observed_tables:
609609
write_disposition = self.write_disposition
610-
wait_for_job = (self.write_disposition != BigQueryDisposition.WRITE_APPEND)
610+
wait_for_job = (
611+
self.write_disposition != BigQueryDisposition.WRITE_APPEND)
611612
self._observed_tables.add(full_table_ref)
612613
Lineage.sinks().add(
613614
'bigquery',

0 commit comments

Comments
 (0)