Commit 19e56b41 authored by Jessica Severin's avatar Jessica Severin
Browse files

reverted back to original worker. New code to catch exceptions at the job

level while not killing worker caused catastrophic hammering of analysis_job
table if there was a problem in the code where by all jobs fail.
parent 49e381ab
......@@ -418,21 +418,15 @@ sub run
}
foreach my $job (@{$jobs}) {
eval {
$self->redirect_job_output($job);
$self->run_module_with_job($job);
$self->close_and_update_job_output($job);
$self->queen->worker_register_job_done($self, $job);
$self->work_done($self->work_done + 1);
};
if($@) {
#job threw an exception so it had a problem
printf("job %d failed with exception: $@\n", $job->dbID);
$self->queen->db->get_AnalysisJobAdaptor->reset_dead_job_by_dbID($job->dbID);
}
}
$self->{'_work_done'}++;
}
my $batch_end = time() * 1000;
#printf("batch start:%f end:%f\n", $batch_start, $batch_end);
$self->db->get_AnalysisStatsAdaptor->
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment