This makes it consistent with what JobQueueGroup actually expects.
Change-Id: Id6c6b3bf19fb1e85a2e3e231d216974d831a2f7c
if ( $mode === 'enqueue' && $update instanceof EnqueueableDataUpdate ) {
// Run only the job enqueue logic to complete the update later
$spec = $update->getAsJobSpecification();
- JobQueueGroup::singleton( $spec['wiki'] )->push( $spec['job'] );
+ $domain = $spec['domain'] ?? $spec['wiki'];
+ JobQueueGroup::singleton( $domain )->push( $spec['job'] );
} elseif ( $update instanceof TransactionRoundDefiningUpdate ) {
$update->doUpdate();
} else {
*/
interface EnqueueableDataUpdate {
/**
- * @return array (wiki => wiki ID, job => IJobSpecification)
+ * @return array (domain => DB domain ID, job => IJobSpecification)
*/
public function getAsJobSpecification();
}
public function getAsJobSpecification() {
return [
- 'wiki' => WikiMap::getWikiIdFromDbDomain( $this->getDB()->getDomainID() ),
- 'job' => new JobSpecification(
+ 'domain' => $this->getDB()->getDomainID(),
+ 'job' => new JobSpecification(
'deleteLinks',
[ 'pageId' => $this->pageId, 'timestamp' => $this->timestamp ],
[ 'removeDuplicates' => true ],
}
return [
- 'wiki' => WikiMap::getWikiIdFromDbDomain( $this->getDB()->getDomainID() ),
+ 'domain' => $this->getDB()->getDomainID(),
'job' => new JobSpecification(
'refreshLinksPrioritized',
[