diff --git a/sdks/python/apache_beam/yaml/yaml_mapping.py b/sdks/python/apache_beam/yaml/yaml_mapping.py
index 86f9f198b687..9f92f59f42b6 100644
--- a/sdks/python/apache_beam/yaml/yaml_mapping.py
+++ b/sdks/python/apache_beam/yaml/yaml_mapping.py
@@ -467,9 +467,9 @@ def expand(self, pcoll):
           break
       else:
         raise ValueError(
-            'The input to this transform does not appear to be an error '
-            + "output.  Expected a schema'd input with a field named "
-            + ' or '.join(repr(fld) for fld in self._ERROR_FIELD_NAMES)
+            'The input to this transform does not appear to be an error ' +
+            "output.  Expected a schema'd input with a field named " +
+            ' or '.join(repr(fld) for fld in self._ERROR_FIELD_NAMES))
 
     if fld is None:
       # This handles with_exception_handling() that returns bare tuples.