2323import threading
2424import types
2525import unittest
26+ from unittest import mock
2627
2728from apache_beam .coders import proto2_coder_test_messages_pb2
2829from apache_beam .internal import cloudpickle_pickler as beam_cloudpickle
3132from apache_beam .internal .cloudpickle_pickler import dumps
3233from apache_beam .internal .cloudpickle_pickler import loads
3334from apache_beam .utils import shared
34- from unittest import mock
3535
3636GLOBAL_DICT_REF = module_test .GLOBAL_DICT
3737
@@ -225,13 +225,11 @@ def test_best_effort_determinism_not_implemented(self):
225225 '\n ' .join (l .output ))
226226
227227 @mock .patch .object (
228- beam_cloudpickle .DEFAULT_CONFIG , 'filepath_interceptor' , autospec = True
229- )
228+ beam_cloudpickle .DEFAULT_CONFIG , 'filepath_interceptor' , autospec = True )
230229 def test_default_config_interceptor (self , mock_filepath_interceptor ):
231230 """Tests config.filepath_interceptor is called for CodeType pickling."""
232231 mock_filepath_interceptor .side_effect = (
233- code_object_pickler .get_normalized_path
234- )
232+ code_object_pickler .get_normalized_path )
235233
236234 def sample_func ():
237235 return "Beam"
@@ -251,10 +249,9 @@ def sample_func():
251249 except AttributeError as e :
252250 if 'get_code_object_params' in str (e ):
253251 self .fail (
254- "Vendored cloudpickle BUG: AttributeError "
255- f"'get_code_object_params' raised during CodeType pickling. "
256- f"Error: { e } "
257- )
252+ "Vendored cloudpickle BUG: AttributeError "
253+ f"'get_code_object_params' raised during CodeType pickling. "
254+ f"Error: { e } " )
258255 else :
259256 raise
260257
0 commit comments