code: def __init__(
      self,
      max_workers: Optional[int] = None,
      cancel_on_error: bool = False,
      **kwargs,
  ):
      super().__init__(max_workers=max_workers, **kwargs)
      self._cancel_on_error = cancel_on_error
  
file_path: dvc/dvc/utils/threadpool.py
imports: import queue
  import sys
  from concurrent import futures
  from itertools import islice
  from typing import Any, Callable, Iterable, Iterator, Optional, Set, TypeVar
label_desc: Use image node_id 1 to create a new ThreadPoolExecutor object from inherited base classes: futures with example: obj = ThreadPoolExecutor(max_workers, cancel_on_error)