View | Details | Raw Unified | Return to bug 39694
Collapse All | Expand All

(-)a/misc/workers/es_indexer_daemon.pl (-5 / +6 lines)
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
- 

Return to bug 39694