#NEWLINE# def _get_result_file( self , r , job_execution ) : #NEWLINE# #INDENT# result = os . path . join ( r . extra [ 'spark-path' ] , 'result' ) #NEWLINE# return r . execute_command ( ( 'cat %s' % result ) , raise_when_error = False )