claudevdm commented on code in PR #34699:
URL: https://github.com/apache/beam/pull/34699#discussion_r2059038480
##########
sdks/python/apache_beam/internal/cloudpickle_pickler.py:
##########
@@ -111,7 +111,7 @@ def dumps(o, enable_trace=True, use_zlib=False) -> bytes:
"""For internal use only; no backwards-compatibility guarantees."""
with _pickle_lock:
with io.BytesIO() as file:
- pickler = cloudpickle.CloudPickler(file)
+ pickler = cloudpickle.PurePythonPickler(file)
Review Comment:
As discussed offline we probably want to have this default to the fast
pickler, and add an option to use slow pickler.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
