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;
}
}
}
}
+/**
+ * @ingroup JobQueue
+ */
class JobQueueAggregatorNull extends JobQueueAggregator {
protected function doNotifyQueueEmpty( $wiki, $type ) {
return true;