Class: Rub2::DeadJobCollector

Inherits:
Object
  • Object
show all
Defined in:
lib/rub2.rb

Instance Method Summary collapse

Instance Method Details

#collect(job_store) ⇒ Object 



248
249
250
251
252
253
254
255
 
# File 'lib/rub2.rb', line 248

def collect(job_store)
  runnning_job_ids = parse_qstat(`qstat -t 2>/dev/null`)
  failed = []
  job_store.each_job do |job|
    failed.push(job) if dead_job?(job, runnning_job_ids)
  end
  job_store.mark_dead_job(failed)
end