#NEWLINE# def testGetStatus( self ) : #NEWLINE# #INDENT# job = map_job . Job . submit ( self . config ) #NEWLINE# self . assertEqual ( map_job . Job . RUNNING , job . get_status ( ) ) #NEWLINE# self . assertEqual ( self . config , job . job_config ) #NEWLINE# tasks = self . taskqueue . GetTasks ( self . config . queue_name ) #NEWLINE# self . taskqueue . FlushQueue ( self . config . queue_name ) #NEWLINE# task = tasks [ 0 ] #NEWLINE# test_support . execute_task ( task ) #NEWLINE# job = map_job . Job . get_job_by_id ( job_id = self . config . job_id ) #NEWLINE# self . assertEqual ( map_job . Job . RUNNING , job . get_status ( ) ) #NEWLINE# self . assertEqual ( job . config , job . job_config ) #NEWLINE# test_support . execute_until_empty ( self . taskqueue ) #NEWLINE# self . assertEqual ( map_job . Job . SUCCESS , job . get_status ( ) )