def Build(self, defn, sink_generator=None):
    if not defn:
      raise ValueError('No definition provided for pipeline.')

    # Here is where we could select different types but for now there is only
    # the PushPipeline.
    defn = self.Scrub(defn, sink_generator)
    return pipelines.PushPipeline(defn)
Constructs a pipeline.
dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/src/pipelines/runner.py/PipelineRunner.Build