#NEWLINE# def test_run_task_as_flow( self ) : #NEWLINE# #INDENT# flow = utils . ProgressingTask ( name = 'task1' ) #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 )