def GetStageClass(type_name):
  type_mod = importlib.import_module(
      ''
      'src.pipelines.stages.' + type_name.lower())
  return getattr(type_mod, type_name)
Converts a callback function to an observable sequence.
dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/src/pipelines/pipelines.py/GetStageClass--crossover with--dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/fromcallback.py/from_callback