Lines 64-70
use Koha::BackgroundJobs;
Link Here
|
64 |
use Koha::SearchEngine; |
64 |
use Koha::SearchEngine; |
65 |
use Koha::SearchEngine::Indexer; |
65 |
use Koha::SearchEngine::Indexer; |
66 |
|
66 |
|
67 |
my ( $help, $batch_size ); |
67 |
my $help; |
|
|
68 |
my $batch_size = 10; |
68 |
|
69 |
|
69 |
my $not_found_retries = {}; |
70 |
my $not_found_retries = {}; |
70 |
my $max_retries = $ENV{MAX_RETRIES} || 10; |
71 |
my $max_retries = $ENV{MAX_RETRIES} || 10; |
Lines 76-83
GetOptions(
Link Here
|
76 |
|
77 |
|
77 |
pod2usage(0) if $help; |
78 |
pod2usage(0) if $help; |
78 |
|
79 |
|
79 |
$batch_size //= 10; |
|
|
80 |
|
81 |
warn "Not using Elasticsearch" unless C4::Context->preference('SearchEngine') eq 'Elasticsearch'; |
80 |
warn "Not using Elasticsearch" unless C4::Context->preference('SearchEngine') eq 'Elasticsearch'; |
82 |
|
81 |
|
83 |
my $logger = Koha::Logger->get( { interface => 'worker' } ); |
82 |
my $logger = Koha::Logger->get( { interface => 'worker' } ); |
Lines 172-178
while (1) {
Link Here
|
172 |
} |
171 |
} |
173 |
|
172 |
|
174 |
} else { |
173 |
} else { |
175 |
@jobs = Koha::BackgroundJobs->search( { status => 'new', queue => 'elastic_index' } )->as_list; |
174 |
@jobs = Koha::BackgroundJobs->search( |
|
|
175 |
{ status => 'new', queue => 'elastic_index' }, |
176 |
{ rows => $batch_size } |
177 |
)->as_list; |
176 |
commit(@jobs); |
178 |
commit(@jobs); |
177 |
@jobs = (); |
179 |
@jobs = (); |
178 |
sleep 10; |
180 |
sleep 10; |
179 |
- |
|
|