claudevdm commented on code in PR #37052:
URL: https://github.com/apache/beam/pull/37052#discussion_r2600257510
##########
sdks/python/apache_beam/options/pipeline_options.py:
##########
@@ -1798,7 +1798,10 @@ def _handle_load_main_session(self, validator):
# save_main_session default to False for dill, while default to true
# for cloudpickle
pickle_library = getattr(self, 'pickle_library')
- if pickle_library in ['default', 'cloudpickle']:
+ if pickle_library == 'default':
+ from apache_beam.internal.pickler import DEFAULT_PICKLE_LIB
+ pickle_library = DEFAULT_PICKLE_LIB
+ if pickle_library == 'cloudpickle':
Review Comment:
Can we only set it to default True for service runner?
--
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]
