X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2Fdeferred%2FDeferredUpdates.php;h=3b7de9df8000a529cdaab670f0d2d9bf593617b3;hb=58d70885d875a3928d96a2ca0a74dbc0ec5bb8bb;hp=67b5490511eecdc6277cec63423382e77a0dde36;hpb=b607b77c504c2af0d0ef4dacd9b892bdb35afeaf;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/deferred/DeferredUpdates.php b/includes/deferred/DeferredUpdates.php index 67b5490511..3b7de9df80 100644 --- a/includes/deferred/DeferredUpdates.php +++ b/includes/deferred/DeferredUpdates.php @@ -263,7 +263,8 @@ class DeferredUpdates { if ( $mode === 'enqueue' && $update instanceof EnqueueableDataUpdate ) { // Run only the job enqueue logic to complete the update later $spec = $update->getAsJobSpecification(); - JobQueueGroup::singleton( $spec['wiki'] )->push( $spec['job'] ); + $domain = $spec['domain'] ?? $spec['wiki']; + JobQueueGroup::singleton( $domain )->push( $spec['job'] ); } elseif ( $update instanceof TransactionRoundDefiningUpdate ) { $update->doUpdate(); } else { @@ -335,7 +336,8 @@ class DeferredUpdates { foreach ( $updates as $update ) { if ( $update instanceof EnqueueableDataUpdate ) { $spec = $update->getAsJobSpecification(); - JobQueueGroup::singleton( $spec['wiki'] )->push( $spec['job'] ); + $domain = $spec['domain'] ?? $spec['wiki']; + JobQueueGroup::singleton( $domain )->push( $spec['job'] ); } else { $remaining[] = $update; }