code: def __init__(self, shuffle: ShuffleRun):
      self.shuffle = shuffle
  
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 PooledRPCShuffle object from inherited base classes: PooledRPCCall with example: obj = PooledRPCShuffle(shuffle)