code: def __init__(self, deserialize: Callable[[Any], Any]) -> None:
      super().__init__(memory_limiter=ResourceLimiter(None))
      self._deserialize = deserialize
      self._shards = defaultdict(deque)
  
file_path: distributed/distributed/shuffle/_memory.py
imports: from __future__ import annotations
  from collections import defaultdict, deque
  from typing import Any, Callable
  from dask.sizeof import sizeof
  from distributed.shuffle._buffer import ShardsBuffer
  from distributed.shuffle._limiter import ResourceLimiter
  from distributed.utils import log_errors
label_desc: Use image node_id 1 to create a new MemoryShardsBuffer object from inherited base classes: ShardsBuffer with example: obj = MemoryShardsBuffer(deserialize)