#NEWLINE# def createEdges( self ) : #NEWLINE# #INDENT# 'computes stage dependencies by examining their inputs/outputs' #NEWLINE# starttime = time . time ( ) #NEWLINE# for i in self . G . nodes_iter ( ) : #NEWLINE# #INDENT# for ip in self . stages [ i ] . inputFiles : #NEWLINE# #INDENT# if self . outputhash . has_key ( ip ) : #NEWLINE# #INDENT# self . G . add_edge ( self . outputhash [ ip ] , i ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# endtime = time . time ( ) #NEWLINE# logger . info ( ( 'Create Edges time: ' + str ( ( endtime - starttime ) ) ) )