Skip to content

Commit 16996bb

Browse files
authored
docs: fix typo and clarify BigQuery error handling method requirements (#37215)
1 parent 207f9d0 commit 16996bb

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

sdks/python/apache_beam/yaml/yaml_io.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,9 +165,12 @@ def write_to_bigquery(
165165
Defaults to `{BigQueryDisposition.WRITE_APPEND}`.
166166
167167
error_handling: If specified, should be a mapping giving an output into
168-
which to emit records that failed to bet written to BigQuery, as
168+
which to emit records that failed to be written to BigQuery, as
169169
described at https://beam.apache.org/documentation/sdks/yaml-errors/
170170
Otherwise permanently failing records will cause pipeline failure.
171+
Note: error_handling requires the Storage Write API method and is not
172+
supported with File Loads (FILE_LOADS method). When error_handling is
173+
specified, the transform will automatically use STORAGE_WRITE_API.
171174
"""
172175
class WriteToBigQueryHandlingErrors(beam.PTransform):
173176
def default_label(self):

0 commit comments

Comments
 (0)