class_docstr: Keep track of high-level timing information for task group progress
class_docstr_tok: ["Keep","track","of","high-level","timing","information","for","task","group","progress"]
code: def __init__(self, scheduler):
      self.scheduler = scheduler
  
      # Time bin size (in seconds). TODO: make this configurable?
      self.dt = 1.0
  
      # Initialize our data structures.
      self._init()
  
imports: from __future__ import annotations
  import asyncio
  import logging
  import warnings
  from collections import defaultdict
  from timeit import default_timer
  from typing import ClassVar
  from tlz import groupby, valmap
  from dask.base import tokenize
  from dask.utils import key_split
  from distributed.diagnostics.plugin import SchedulerPlugin
  from distributed.metrics import time
label_desc: Use image node_id 1 to create a new GroupTiming object from inherited base classes: SchedulerPlugin with example: obj = GroupTiming(scheduler)