@@ -260,17 +260,38 @@ sub reindex {
260
260
my ( $self , $bulk , $source , $status ) = @_ ;
261
261
262
262
# Update the status on the release.
263
- my $release = $self -> model-> doc(' release' )-> get( {
264
- author => $source -> {author },
265
- name => $source -> {release },
263
+ my $releases = $self -> es-> search( {
264
+ es_doc_path(' release' ),
265
+ body => {
266
+ query => {
267
+ bool => {
268
+ must => [
269
+ { term => { author => $source -> {author } } },
270
+ { term => { name => $source -> {release } } },
271
+ ],
272
+ },
273
+ },
274
+ },
275
+ _source => false,
266
276
} );
277
+ my $release = $releases -> {hits }{hits }[0]{_id };
267
278
268
- $release -> _set_status($status );
269
279
log_info {
270
280
$status eq ' latest' ? ' Upgrading ' : ' Downgrading ' ,
271
- ' release ' , $release -> name || q[ ] ;
281
+ ' release ' , $source -> { release }, " ( $release ) " ;
272
282
};
273
- $release -> put unless ( $self -> dry_run );
283
+
284
+ if ( !$self -> dry_run ) {
285
+ $self -> es-> update( {
286
+ es_doc_path(' release' ),
287
+ id => $release ,
288
+ body => {
289
+ doc => {
290
+ status => $status ,
291
+ },
292
+ },
293
+ } );
294
+ }
274
295
275
296
# Get all the files for the release.
276
297
my $scroll = $self -> es-> scroll_helper(
0 commit comments