doc changes

apache · Jan 20, 2023 · 21adb6f · 21adb6f
1 parent 89bed0d
commit 21adb6f
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/sdks/python/apache_beam/io/gcp/bigquery.py b/sdks/python/apache_beam/io/gcp/bigquery.py
@@ -2332,8 +2332,10 @@ class StorageWriteToBigQuery(PTransform):
  use_at_least_once=False))
 
  _ = (result['failed_rows_with_errors']
- | beam.Map(lambda e: "failed row id: %s, error: %s" %
- (e.failed_row.id, e.error_message)))
+ | 'Format errors' >> beam.Map(
+ lambda e: "failed row id: %s, error: %s" %
+ (e.failed_row.id, e.error_message))
+ | 'Write errors' >> beam.io.WriteToText(<output>)))
 
  """
  URN = "beam:schematransform:org.apache.beam:bigquery_storage_write:v1"