code: def getStream(group: str):
      if group in _metrics_map:
          handler = _metrics_map[group]
      else:
          handler = _default_metrics_handler
      return MetricStream(group, handler)
  
imports: import abc
  import time
  import warnings
  from collections import namedtuple
  from functools import wraps
  from typing import Dict, Optional
label_desc: Use image node_id 2 for calling a global function with example usage: getStream(group) and returns: MetricStream