|
Lines 119-126
while (1) {
Link Here
|
| 119 |
} else { |
119 |
} else { |
| 120 |
my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues }); |
120 |
my $jobs = Koha::BackgroundJobs->search({ status => 'new', queue => \@queues }); |
| 121 |
while ( my $job = $jobs->next ) { |
121 |
while ( my $job = $jobs->next ) { |
| 122 |
my $args = $job->json->decode($job->data); |
122 |
my $args = try { |
|
|
123 |
$job->json->decode($job->data); |
| 124 |
} catch { |
| 125 |
Koha::Logger->get->warn(sprintf "Cannot decode data for job id=%s", $job->id); |
| 126 |
$job->status('failed')->store; |
| 127 |
}; |
| 128 |
|
| 129 |
next unless $args; |
| 130 |
|
| 123 |
process_job( $job, { job_id => $job->id, %$args } ); |
131 |
process_job( $job, { job_id => $job->id, %$args } ); |
|
|
132 |
|
| 124 |
} |
133 |
} |
| 125 |
sleep 10; |
134 |
sleep 10; |
| 126 |
} |
135 |
} |
| 127 |
- |
|
|