Skip to content

Commit

Permalink
test revert _beam_schema_proto (#29754) (#29759)
Browse files Browse the repository at this point in the history
  • Loading branch information
riteshghorse authored Dec 14, 2023
1 parent f773123 commit 03e9036
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion sdks/python/apache_beam/typehints/schemas.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 03e9036

Please sign in to comment.