#NEWLINE# def test_parallel_flow_one_task( self ) : #NEWLINE# #INDENT# flow = uf . Flow ( 'p-1' ) . add ( utils . ProgressingTask ( name = 'task1' , provides = 'a' ) ) #NEWLINE# engine = self . _make_engine ( flow ) #NEWLINE# with utils . CaptureListener ( engine , capture_flow = False ) as capturer : #NEWLINE# #INDENT# engine . run ( ) #NEWLINE# #UNINDENT# expected = [ 'task1.t RUNNING' , 'task1.t SUCCESS(5)' ] #NEWLINE# self . assertEqual ( expected , capturer . values ) #NEWLINE# self . assertEqual ( { #NEWLINE# #INDENT# 'a' : 5 , #NEWLINE# #UNINDENT# } , engine . storage . fetch_all ( ) )