#NEWLINE# def add_output( self , pipe ) : #NEWLINE# #INDENT# if ( self not in self . outputs ) : #NEWLINE# #INDENT# self . outputs . append ( pipe ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise Exception ( ( 'Output %s already connected' % pipe ) )