You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jr...@apache.org on 2023/12/14 16:10:01 UTC

(beam) branch release-2.53.0 updated: test revert _beam_schema_proto (#29754) (#29759)

This is an automated email from the ASF dual-hosted git repository.

jrmccluskey pushed a commit to branch release-2.53.0
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/release-2.53.0 by this push:
     new 03e90360272 test revert _beam_schema_proto (#29754) (#29759)
03e90360272 is described below

commit 03e90360272ba35ffd15a6e2a10a70d984dc3be1
Author: Ritesh Ghorse <ri...@gmail.com>
AuthorDate: Thu Dec 14 11:09:54 2023 -0500

    test revert _beam_schema_proto (#29754) (#29759)
---
 sdks/python/apache_beam/typehints/schemas.py | 1 -
 1 file changed, 1 deletion(-)

diff --git a/sdks/python/apache_beam/typehints/schemas.py b/sdks/python/apache_beam/typehints/schemas.py
index 6a6544aaa07..b8176dccb8e 100644
--- a/sdks/python/apache_beam/typehints/schemas.py
+++ b/sdks/python/apache_beam/typehints/schemas.py
@@ -561,7 +561,6 @@ class SchemaTranslation(object):
         '__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)