class_docstr: An interface to schedule exchange tasks (`exchange_spec`) for multi-nodes
  execution.
class_docstr_tok: ["An","interface","to","schedule","exchange","tasks","(","`","exchange_spec","`",")","for","multi-nodes","execution","."]
docstr: Args:
      exchange_spec: The implementation of exchange tasks to execute.
docstr_tok: ["Args",":","exchange_spec",":","The","implementation","of","exchange","tasks","to","execute","."]
code: def __init__(self, exchange_spec: ExchangeTaskSpec):
      """
      Args:
          exchange_spec: The implementation of exchange tasks to execute.
      """
      self._exchange_spec = exchange_spec
  
file_path: ray/python/ray/data/_internal/planner/exchange/interfaces.py
imports: from typing import Any, Dict, List, Optional, Tuple, Union
  from ray.data._internal.execution.interfaces import RefBundle
  from ray.data._internal.stats import StatsDict
  from ray.data.block import Block, BlockMetadata
label_desc: Use image node_id 1 to create a new ExchangeTaskScheduler object  with example: obj = ExchangeTaskScheduler(exchange_spec)