diff options
Diffstat (limited to 'includes/jobqueue/JobQueueDB.php')
| -rw-r--r-- | includes/jobqueue/JobQueueDB.php | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/includes/jobqueue/JobQueueDB.php b/includes/jobqueue/JobQueueDB.php index 08873cc1..d5f47ffd 100644 --- a/includes/jobqueue/JobQueueDB.php +++ b/includes/jobqueue/JobQueueDB.php @@ -221,7 +221,7 @@ class JobQueueDB extends JobQueue { } $rowSet = array(); // (sha1 => job) map for jobs that are de-duplicated - $rowList = array(); // list of jobs for jobs that are are not de-duplicated + $rowList = array(); // list of jobs for jobs that are not de-duplicated foreach ( $jobs as $job ) { $row = $this->insertFields( $job ); if ( $job->ignoreDuplicates() ) { @@ -556,7 +556,7 @@ class JobQueueDB extends JobQueue { * @return void */ protected function doWaitForBackups() { - wfWaitForSlaves(); + wfWaitForSlaves( false, $this->wiki, $this->cluster ?: false ); } /** @@ -686,7 +686,9 @@ class JobQueueDB extends JobQueue { $affected = $dbw->affectedRows(); $count += $affected; JobQueue::incrStats( 'job-recycle', $this->type, $affected, $this->wiki ); + // The tasks recycled jobs or release delayed jobs into the queue $this->cache->set( $this->getCacheKey( 'empty' ), 'false', self::CACHE_TTL_LONG ); + $this->aggr->notifyQueueNonEmpty( $this->wiki, $this->type ); } } |