Enable cloudpickle default

.github/trigger_files/beam_PostCommit_Python.json

@@ -1,6 +1,10 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to run.",
   "https://github.com/apache/beam/pull/32440": "test new datastream runner for batch"
+<<<<<<< HEAD
   "modification": 9
+=======
+  "modification": 10
+>>>>>>> Trigger postcommits.
 }
 

.github/trigger_files/beam_PostCommit_Python_ValidatesContainer_Dataflow.json

@@ -1,4 +1,4 @@
 {
     "comment": "Modify this file in a trivial way to cause this test suite to run",
-    "modification": 2
+    "modification": 3
 }

.github/trigger_files/beam_PostCommit_Python_Xlang_Gcp_Dataflow.json

@@ -1,4 +1,8 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to run",
+<<<<<<< HEAD
   "modification": 10
+=======
+  "modification": 12
+>>>>>>> Trigger postcommits.
 }

.github/trigger_files/beam_PostCommit_Python_Xlang_Gcp_Direct.json

@@ -1,4 +1,4 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to run",
-  "modification": 5
+  "modification": 6
 }

.github/trigger_files/beam_PostCommit_Python_Xlang_IO_Dataflow.json

@@ -1,4 +1,4 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to run",
-  "modification": 3
+  "modification": 4
 }

.github/trigger_files/beam_PostCommit_Python_Xlang_IO_Direct.json

@@ -1,4 +1,4 @@
 {
   "comment": "Modify this file in a trivial way to cause this test suite to run",
-  "modification": 1
+  "modification": 2
 }

sdks/python/apache_beam/internal/pickler.py

@@ -33,9 +33,9 @@
 
 USE_CLOUDPICKLE = 'cloudpickle'
 USE_DILL = 'dill'
-DEFAULT_PICKLE_LIB = USE_DILL
+DEFAULT_PICKLE_LIB = USE_CLOUDPICKLE
 
-desired_pickle_lib = dill_pickler
+desired_pickle_lib = cloudpickle_pickler
 
 
 def dumps(o, enable_trace=True, use_zlib=False) -> bytes:
@@ -66,6 +66,7 @@ def load_session(file_path):
 
 def set_library(selected_library=DEFAULT_PICKLE_LIB):
   """ Sets pickle library that will be used. """
+  selected_library = USE_CLOUDPICKLE
   global desired_pickle_lib
   # If switching to or from dill, update the pickler hook overrides.
   if (selected_library == USE_DILL) != (desired_pickle_lib == dill_pickler):

sdks/python/apache_beam/pipeline_test.py

@@ -288,7 +288,7 @@ def test_auto_unique_labels(self):
 
     opts = PipelineOptions(["--auto_unique_labels"])
     with mock.patch.object(uuid, 'uuid4') as mock_uuid_gen:
-      mock_uuids = [mock.Mock(hex='UUID01XXX'), mock.Mock(hex='UUID02XXX')]
+      mock_uuids = [mock.Mock(hex=f'UUID0{i}XXX') for i in range(1, 20)]
       mock_uuid_gen.side_effect = mock_uuids
       with TestPipeline(options=opts) as pipeline:
         pcoll = pipeline | 'pcoll' >> Create([1, 2, 3])