global $wgLocalDatabases;
$pendingDBs = []; // (job type => (db list))
- foreach ( $wgLocalDatabases as $db ) {
- foreach ( JobQueueGroup::singleton( $db )->getQueuesWithJobs() as $type ) {
- $pendingDBs[$type][] = $db;
+ foreach ( $wgLocalDatabases as $wikiId ) {
+ foreach ( JobQueueGroup::singleton( $wikiId )->getQueuesWithJobs() as $type ) {
+ $pendingDBs[$type][] = $wikiId;
}
}
return $pendingDBs;
}
}
-
-/**
- * @ingroup JobQueue
- */
-class JobQueueAggregatorNull extends JobQueueAggregator {
- protected function doNotifyQueueEmpty( $wiki, $type ) {
- return true;
- }
-
- protected function doNotifyQueueNonEmpty( $wiki, $type ) {
- return true;
- }
-
- protected function doGetAllReadyWikiQueues() {
- return [];
- }
-
- protected function doPurge() {
- return true;
- }
-}