diff --git a/sdks/python/apache_beam/io/gcp/bigquery.py b/sdks/python/apache_beam/io/gcp/bigquery.py
index db7c108826969..bb2cdcceb231f 100644
--- 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"