Lines 75-82
$batch_size //= 10;
Link Here
|
75 |
|
75 |
|
76 |
die "Not using Elasticsearch" unless C4::Context->preference('SearchEngine') eq 'Elasticsearch'; |
76 |
die "Not using Elasticsearch" unless C4::Context->preference('SearchEngine') eq 'Elasticsearch'; |
77 |
|
77 |
|
78 |
my $logger = Koha::Logger->get; |
78 |
my $logger = Koha::Logger->get({ interface => 'worker' }); |
79 |
$logger->debug_to_screen; |
|
|
80 |
|
79 |
|
81 |
my $conn; |
80 |
my $conn; |
82 |
try { |
81 |
try { |
Lines 113-119
while (1) {
Link Here
|
113 |
my $body = $frame->body; |
112 |
my $body = $frame->body; |
114 |
decode_json($body); # TODO Should this be from_json? Check utf8 flag. |
113 |
decode_json($body); # TODO Should this be from_json? Check utf8 flag. |
115 |
} catch { |
114 |
} catch { |
116 |
$logger->debug(sprintf "Frame not processed - %s", $_); |
115 |
$logger->warn(sprintf "Frame not processed - %s", $_); |
117 |
return; |
116 |
return; |
118 |
} finally { |
117 |
} finally { |
119 |
$conn->ack( { frame => $frame } ); |
118 |
$conn->ack( { frame => $frame } ); |
Lines 126-132
while (1) {
Link Here
|
126 |
my $job = Koha::BackgroundJobs->find($args->{job_id}); |
125 |
my $job = Koha::BackgroundJobs->find($args->{job_id}); |
127 |
|
126 |
|
128 |
unless ( $job ) { |
127 |
unless ( $job ) { |
129 |
$logger->debug(sprintf "No job found for id=%s", $args->{job_id}); |
128 |
$logger->warn(sprintf "No job found for id=%s", $args->{job_id}); |
130 |
next; |
129 |
next; |
131 |
} |
130 |
} |
132 |
|
131 |
|
Lines 158-164
sub commit {
Link Here
|
158 |
my $args = try { |
157 |
my $args = try { |
159 |
$job->json->decode($job->data); |
158 |
$job->json->decode($job->data); |
160 |
} catch { |
159 |
} catch { |
161 |
$logger->debug(sprintf "Cannot decode data for job id=%s", $job->id); |
160 |
$logger->warn(sprintf "Cannot decode data for job id=%s", $job->id); |
162 |
$job->status('failed')->store; |
161 |
$job->status('failed')->store; |
163 |
return; |
162 |
return; |
164 |
}; |
163 |
}; |
Lines 174-187
sub commit {
Link Here
|
174 |
try { |
173 |
try { |
175 |
$auth_indexer->update_index(\@auth_records); |
174 |
$auth_indexer->update_index(\@auth_records); |
176 |
} catch { |
175 |
} catch { |
177 |
$logger->debug(sprintf "Update of elastic index failed with: %s", $_); |
176 |
$logger->warn(sprintf "Update of elastic index failed with: %s", $_); |
178 |
}; |
177 |
}; |
179 |
} |
178 |
} |
180 |
if( @bib_records ){ |
179 |
if( @bib_records ){ |
181 |
try { |
180 |
try { |
182 |
$biblio_indexer->update_index(\@bib_records); |
181 |
$biblio_indexer->update_index(\@bib_records); |
183 |
} catch { |
182 |
} catch { |
184 |
$logger->debug(sprintf "Update of elastic index failed with: %s", $_); |
183 |
$logger->warn(sprintf "Update of elastic index failed with: %s", $_); |
185 |
}; |
184 |
}; |
186 |
} |
185 |
} |
187 |
|
186 |
|
188 |
- |
|
|