File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sdks/python/apache_beam/internal Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -80,6 +80,9 @@ def set_library(selected_library=DEFAULT_PICKLE_LIB):
8080 """ Sets pickle library that will be used. """
8181 global desired_pickle_lib
8282
83+ if selected_library == 'default' :
84+ selected_library = DEFAULT_PICKLE_LIB
85+
8386 if selected_library == USE_DILL and not dill_pickler :
8487 raise ImportError (
8588 "Pipeline option pickle_library=dill is set, but dill is not "
@@ -98,9 +101,6 @@ def set_library(selected_library=DEFAULT_PICKLE_LIB):
98101 if is_currently_dill != dill_is_requested :
99102 dill_pickler .override_pickler_hooks (selected_library == USE_DILL )
100103
101- if selected_library == 'default' :
102- selected_library = DEFAULT_PICKLE_LIB
103-
104104 if dill_is_requested :
105105 desired_pickle_lib = dill_pickler
106106 elif selected_library == USE_CLOUDPICKLE :
You can’t perform that action at this time.
0 commit comments