#NEWLINE# def compute( self ) : #NEWLINE# #INDENT# if connector_list . pvInstance : #NEWLINE# #INDENT# del self . pvInstance #NEWLINE# #UNINDENT# pv . SetActiveSource ( None ) #NEWLINE# if ( not self . pvInstance ) : #NEWLINE# #INDENT# if hasattr ( self , 'pvFunction' ) : #NEWLINE# #INDENT# self . pvInstance = self . pvFunction ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . pvInstance = getattr ( pv , self . pvClass ) ( ) #NEWLINE# #UNINDENT# #UNINDENT# if self . inputPorts . has_key ( 'Input' ) : #NEWLINE# #INDENT# inp = extract_pv_instances ( self . force_get_input_list ( 'Input' ) ) [ 0 ] #NEWLINE# setattr ( self . pvInstance , 'Input' , inp ) #NEWLINE# #UNINDENT# for ( function , connector_list ) in self . inputPorts . iteritems ( ) : #NEWLINE# #INDENT# paramList = extract_pv_instances ( self . force_get_input_list ( function ) ) #NEWLINE# if ( function != 'Input' ) : #NEWLINE# #INDENT# if ( len ( paramList ) > 1 ) : #NEWLINE# #INDENT# setattr ( self . pvInstance , function , paramList ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# setattr ( self . pvInstance , function , paramList [ 0 ] ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# if hasattr ( self . pvInstance , 'UpdatePipeline' ) : #NEWLINE# #INDENT# self . pvInstance . UpdatePipeline ( ) #NEWLINE# #UNINDENT# self . set_output ( 'Output' , self )