code: def __init__(self, *args, **kwargs):
      self.shuffles = {}
  
file_path: distributed/distributed/shuffle/tests/utils.py
imports: from __future__ import annotations
  import itertools
  from typing import Any
  from distributed.core import PooledRPCCall
  from distributed.shuffle._core import ShuffleId, ShuffleRun
label_desc: Use image node_id 1 to create a new AbstractShuffleTestPool object  with example: obj = AbstractShuffleTestPool()