#NEWLINE# def checkStreams( self , graph ) : #NEWLINE# #INDENT# for tier in self . pipelinesByTier : #NEWLINE# #INDENT# for pipeline in self . pipelinesByTier [ tier ] : #NEWLINE# #INDENT# data = self . getPipelineData ( pipeline ) #NEWLINE# for task in data . pipelineTasks : #NEWLINE# #INDENT# if data . pipelineTasks [ task ] . pipeline : #NEWLINE# #INDENT# if data . getTaskAttribute ( task , 'isInputStream' ) : #NEWLINE# #INDENT# isStreamSet = False #NEWLINE# for pipelineTask in graph . workflow : #NEWLINE# #INDENT# if pipelineTask . startswith ( task ) : #NEWLINE# #INDENT# isStreamSet = True #NEWLINE# graph . setGraphNodeAttribute ( pipelineTask , 'isInputStream' , True ) #NEWLINE# graph . setGraphNodeAttribute ( pipelineTask , 'isGreedy' , False ) #NEWLINE# break #NEWLINE# #UNINDENT# #UNINDENT# if ( not isStreamSet ) : #NEWLINE# #INDENT# print ( 'NO STREAM SET - superpipeline.checkStreams' ) #NEWLINE# exit ( 1 ) #NEWLINE# #UNINDENT# #UNINDENT# if data . getTaskAttribute ( task , 'isOutputStream' ) : #NEWLINE# #INDENT# isStreamSet = False #NEWLINE# for pipelineTask in reversed ( graph . workflow ) : #NEWLINE# #INDENT# if pipelineTask . startswith ( task ) : #NEWLINE# #INDENT# isStreamSet = True #NEWLINE# graph . setGraphNodeAttribute ( pipeline , 'isOutputStream' , True ) #NEWLINE# break #NEWLINE# #UNINDENT# #UNINDENT# if ( not isStreamSet ) : #NEWLINE# #INDENT# print ( 'NO STREAM SET - superpipeline.checkStreams' ) #NEWLINE# exit ( 1 )