Update DeferredUpdates::enqueueUpdates() to look for the DB domain
authorAaron Schulz <aschulz@wikimedia.org>
Fri, 29 Mar 2019 03:47:09 +0000 (20:47 -0700)
committerAaron Schulz <aschulz@wikimedia.org>
Fri, 29 Mar 2019 04:04:05 +0000 (04:04 +0000)
Change-Id: I2c786eba61ff36a9e0e2d605aa3108c9c8569063

includes/deferred/DeferredUpdates.php

index 3043c10..3b7de9d 100644 (file)
@@ -336,7 +336,8 @@ class DeferredUpdates {
                foreach ( $updates as $update ) {
                        if ( $update instanceof EnqueueableDataUpdate ) {
                                $spec = $update->getAsJobSpecification();
-                               JobQueueGroup::singleton( $spec['wiki'] )->push( $spec['job'] );
+                               $domain = $spec['domain'] ?? $spec['wiki'];
+                               JobQueueGroup::singleton( $domain )->push( $spec['job'] );
                        } else {
                                $remaining[] = $update;
                        }