code: def __init__(
      self,
      keys,
      scheduler=None,
      interval="100ms",
      width=40,
      loop=None,
      complete=True,
      start=True,
      **kwargs,
  ):
      self._loop_runner = loop_runner = LoopRunner(loop=loop)
      super().__init__(keys, scheduler, interval, complete)
      self.width = width
  
      if start:
          loop_runner.run_sync(self.listen)
  
imports: from __future__ import annotations
  import html
  import logging
  import sys
  import warnings
  import weakref
  from contextlib import suppress
  from timeit import default_timer
  from typing import Callable
  from tlz import valmap
  from tornado.ioloop import IOLoop
  import dask
  from dask.utils import key_split
  from distributed.client import default_client, futures_of
  from distributed.core import CommClosedError, clean_exception, coerce_to_address, connect
  from distributed.diagnostics.progress import MultiProgress, Progress, format_time
  from distributed.protocol.pickle import dumps
  from distributed.utils import LoopRunner, is_kernel
label_desc: Use image node_id 1 to create a new TextProgressBar object from inherited base classes: ProgressBar with example: obj = TextProgressBar(keys, scheduler, interval, width, loop, complete, start)