diff --git a/sdks/python/apache_beam/typehints/schemas.py b/sdks/python/apache_beam/typehints/schemas.py index 6a6544aaa07c..b8176dccb8e2 100644 --- a/sdks/python/apache_beam/typehints/schemas.py +++ b/sdks/python/apache_beam/typehints/schemas.py @@ -561,7 +561,6 @@ def named_tuple_from_schema(self, schema: schema_pb2.Schema) -> type: '__reduce__', _named_tuple_reduce_method(schema.SerializeToString())) setattr(user_type, row_type._BEAM_SCHEMA_ID, schema.id) - user_type._beam_schema_proto = _Ephemeral(schema) self.schema_registry.add(user_type, schema) coders.registry.register_coder(user_type, coders.RowCoder)