X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2Fjobqueue%2FJobQueueFederated.php;h=8b5a62ef54cfd663fe9830384073266820ee38c8;hb=e3c745fea0c5231cc425a0223c9d4567152171a0;hp=30ab7e739b033c18e01b416bade1bcff79656268;hpb=54a8b9a14f42b063a143a981067ba564860ec556;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/jobqueue/JobQueueFederated.php b/includes/jobqueue/JobQueueFederated.php index 30ab7e739b..8b5a62ef54 100644 --- a/includes/jobqueue/JobQueueFederated.php +++ b/includes/jobqueue/JobQueueFederated.php @@ -199,7 +199,7 @@ class JobQueueFederated extends JobQueue { * @param HashRing &$partitionRing * @param int $flags * @throws JobQueueError - * @return array List of Job object that could not be inserted + * @return IJobSpecification[] List of Job object that could not be inserted */ protected function tryJobInsertions( array $jobs, HashRing &$partitionRing, $flags ) { $jobsLeft = []; @@ -299,7 +299,7 @@ class JobQueueFederated extends JobQueue { return false; } - protected function doAck( Job $job ) { + protected function doAck( RunnableJob $job ) { $partition = $job->getMetadata( 'QueuePartition' ); if ( $partition === null ) { throw new MWException( "The given job has no defined partition name." ); @@ -308,7 +308,7 @@ class JobQueueFederated extends JobQueue { $this->partitionQueues[$partition]->ack( $job ); } - protected function doIsRootJobOldDuplicate( Job $job ) { + protected function doIsRootJobOldDuplicate( IJobSpecification $job ) { $signature = $job->getRootJobParams()['rootJobSignature']; $partition = $this->partitionRing->getLiveLocation( $signature ); try {