X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2Fjobqueue%2FJobQueueFederated.php;h=bd832dbcd6946aa44339e1f8d061fdfcf87d892b;hb=96f35d42d78e97bb620ec8b6134b427bd793ed2c;hp=c1272393608b6040f941a1c8aadbb51899c739d1;hpb=c161c46d26c24643d7fced554ab6e45fb8ec7529;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/jobqueue/JobQueueFederated.php b/includes/jobqueue/JobQueueFederated.php index c127239360..bd832dbcd6 100644 --- a/includes/jobqueue/JobQueueFederated.php +++ b/includes/jobqueue/JobQueueFederated.php @@ -49,7 +49,7 @@ class JobQueueFederated extends JobQueue { /** @var HashRing */ protected $partitionRing; - /** @var array (partition name => JobQueue) reverse sorted by weight */ + /** @var JobQueue[] (partition name => JobQueue) reverse sorted by weight */ protected $partitionQueues = []; /** @var int Maximum number of partitions to try */ @@ -311,7 +311,7 @@ class JobQueueFederated extends JobQueue { throw new MWException( "The given job has no defined partition name." ); } - return $this->partitionQueues[$job->metadata['QueuePartition']]->ack( $job ); + $this->partitionQueues[$job->metadata['QueuePartition']]->ack( $job ); } protected function doIsRootJobOldDuplicate( Job $job ) {