#NEWLINE# def Build( self , defn , sink_generator = None ) : #NEWLINE# #INDENT# "Constructs a pipeline.\n\n    Args:\n      defn: The linted pipeline definition as a dictionary of stages.\n        Looks like:\n        {\n          'inputs': [],\n          'transforms': [],\n          'outputs': [],\n          'options': {},\n        }\n      sink_generator: Required for filling in missing stage output sinks.\n\n    Returns:\n      An asynchronous pipeline made up of the defined stages.\n\n    Raises:\n      ValueError: If no definition is provided.\n    " #NEWLINE# if ( not self ) : #NEWLINE# #INDENT# raise ValueError ( 'No definition provided for pipeline.' ) #NEWLINE# #UNINDENT# defn = self . Scrub ( defn , sink_generator ) #NEWLINE# return pipelines . PushPipeline ( defn )