#NEWLINE# def test_graph_flow_two_independent_tasks( self ) : #NEWLINE# #INDENT# flow = gf . Flow ( 'g-2' ) . add ( utils . ProgressingTask ( name = 'task1' ) , utils . ProgressingTask ( name = 'task2' ) ) #NEWLINE# engine = self . _make_engine ( flow ) #NEWLINE# with utils . CaptureListener ( engine , capture_flow = False ) as capturer : #NEWLINE# #INDENT# engine . run ( ) #NEWLINE# #UNINDENT# expected = set ( [ 'task2.t SUCCESS(5)' , 'task2.t RUNNING' , 'task1.t RUNNING' , 'task1.t SUCCESS(5)' ] ) #NEWLINE# self . assertEqual ( expected , set ( capturer . values ) ) #NEWLINE# self . assertEqual ( 2 , len ( flow ) )