remove unecessary job scrub

This commit is contained in:
Oliver Gorwits
2014-05-17 19:50:37 +01:00
parent 60522fe555
commit 46ebe4cd6a

View File

@@ -21,10 +21,7 @@ sub worker_body {
foreach my $job (@$jobs) {
my $target = $self->munge_action($job->action);
next unless $self->can($target);
debug sprintf "$type ($wid): can ${target}() for job %s", $job->id;
# do job
try {
$job->started(scalar localtime);
info sprintf "$type (%s): starting %s job(%s) at %s",
@@ -63,9 +60,6 @@ sub close_job {
$job->finished($now);
$self->jq_complete($job);
}
# remove job from local queue
$self->do('scrub_jobs', $self->wid);
}
catch { $self->sendto('stderr', "error closing job: $_\n") };
}