#NEWLINE# def generatePipeline( self , serializer ) : #NEWLINE# #INDENT# todo = set ( ) #NEWLINE# for e in self . entryPoints : #NEWLINE# #INDENT# todo . add ( e ) #NEWLINE# #UNINDENT# self . generatePipelineInternal ( serializer , todo , self . egressEntry ) #NEWLINE# todo = set ( ) #NEWLINE# todo . add ( self . egressEntry ) #NEWLINE# self . generatePipelineInternal ( serializer , serializer , None )