#NEWLINE# def _recover_active_job( self , job_id ) : #NEWLINE# #INDENT# command_line = self . _job_directory ( job_id ) . load_metadata ( JOB_FILE_COMMAND_LINE , None ) #NEWLINE# if self : #NEWLINE# #INDENT# self . work_queue . put ( ( RUN , ( job_id , command_line ) ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# raise Exception ( ( 'Cannot recover job with id %s' % job_id ) )