def GetStage(stage_defn):
  return GetStageClass(stage_defn.get('type'))(stage_defn)
Get the pipe for a given config dict with optional input.
dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/src/pipelines/pipelines.py/GetStage