#NEWLINE# def test_missing_job_id( self ) : #NEWLINE# #INDENT# self . runner . get_hadoop_version . return_value = '1.0.3' #NEWLINE# log_interpretation = dict ( step = dict ( app_id = 'app_1' ) ) #NEWLINE# self . runner . _interpret_task_logs ( log_interpretation ) #NEWLINE# self . assertEqual ( log_interpretation , dict ( step = dict ( app_id = 'app_1' ) ) ) #NEWLINE# self . assertTrue ( self . log . warning . called ) #NEWLINE# self . assertFalse ( self . _interpret_task_logs . called ) #NEWLINE# self . assertFalse ( log_interpretation . runner . _ls_task_syslogs . called )