#NEWLINE# def job_finish( self , p ) : #NEWLINE# #INDENT# r = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# r [ 'output' ] = r [ 'output' ] #NEWLINE# r [ 'workdir' ] = p [ 'workdir' ] #NEWLINE# r [ 'job_identifier' ] = p [ 'job_identifier' ] #NEWLINE# self . annotate ( { #NEWLINE# #INDENT# 'hadoop_log' : self . job . standard_error ( ) , #NEWLINE# #UNINDENT# } ) #NEWLINE# if self . job . failed ( ) : #NEWLINE# #INDENT# error = self . job . standard_error ( ) #NEWLINE# raise ModuleError ( self , error ) #NEWLINE# #UNINDENT# return r