diff --git a/distributed/protocol/__init__.py b/distributed/protocol/__init__.py index 4aa87deadd..736f093a64 100644 --- a/distributed/protocol/__init__.py +++ b/distributed/protocol/__init__.py @@ -14,7 +14,6 @@ dask_serialize, deserialize, deserialize_bytes, - nested_deserialize, register_generic, register_serialization, register_serialization_family, diff --git a/distributed/protocol/serialize.py b/distributed/protocol/serialize.py index 789c90fe2a..b4884bea0d 100644 --- a/distributed/protocol/serialize.py +++ b/distributed/protocol/serialize.py @@ -3,7 +3,6 @@ import codecs import importlib import traceback -import warnings from array import array from enum import Enum from functools import partial @@ -624,21 +623,13 @@ def __ne__(self, other): return not (self == other) -def nested_deserialize(x): - warnings.warn( - "nested_deserialize is deprecated and will be removed in a future release.", - DeprecationWarning, - ) - return _nested_deserialize(x, emulate_deserialize=True) - - def _nested_deserialize(x, emulate_deserialize=True): """ Replace all Serialize and Serialized values nested in *x* with the original values. Returns a copy of *x*. >>> msg = {'op': 'update', 'data': to_serialize(123)} - >>> nested_deserialize(msg) + >>> _nested_deserialize(msg) {'op': 'update', 'data': 123} """