Commit df9ca5a9 authored by Leo Gordon's avatar Leo Gordon
Browse files

moved Worker's call to Queen->safe_synchronize_AnalysisStats into Worker.pm for clarity

parent 4b517d33
......@@ -345,8 +345,6 @@ sub worker_check_in {
my $sth = $self->prepare($sql);
$sth->execute();
$sth->finish;
$self->safe_synchronize_AnalysisStats($worker->analysis->stats);
}
......
......@@ -569,7 +569,8 @@ sub run_one_batch {
my $max_retry_count = $self->analysis->stats->max_retry_count(); # a constant (as the Worker is already specialized by the Queen) needed later for retrying jobs
$self->queen->worker_check_in($self); #will sync analysis_stats if needed
$self->queen->worker_check_in($self);
$self->queen->safe_synchronize_AnalysisStats($self->analysis->stats);
$self->cause_of_death('NO_WORK') unless(scalar @{$jobs});
......
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