diff --git a/sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py b/sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py index 345ebf8f507ef..e4d03c864bf86 100644 --- a/sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py +++ b/sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py @@ -351,8 +351,10 @@ def wrapper(self, *args): class TransformContext(object): _KNOWN_CODER_URNS = set( - value.urn for key, - value in common_urns.coders.__dict__.items() if not key.startswith('_')) + value.urn for (key, value) in common_urns.coders.__dict__.items() + if not key.startswith('_') + # Length prefix Rows rather than re-coding them. + ) - set([common_urns.coders.ROW.urn]) def __init__( self,