diff --git a/sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py b/sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py index 5a9d89430fd3..e4fbf0c72f87 100644 --- a/sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py +++ b/sdks/python/apache_beam/internal/cloudpickle/cloudpickle.py @@ -1483,8 +1483,7 @@ def save_global(self, obj, name=None, pack=struct.pack): def save_typevar(self, obj, name=None): """Handle TypeVar objects with access to config.""" - return self._save_reduce_pickle5( - *_typevar_reduce(obj, self.config), obj=obj) + return self.save_reduce(*_typevar_reduce(obj, self.config), obj=obj) dispatch[typing.TypeVar] = save_typevar