Make executeReadyPeriodicTasks() notify the aggregator when jobs are released/recycled

Change-Id: I69459f9a9f37c1d1307a9c48c37cb6063a934fa5

diff --git a/includes/job/JobQueueGroup.php b/includes/job/JobQueueGroup.php
index 4f11bbf..cf0c290 100644 (file)
--- a/includes/job/JobQueueGroup.php
+++ b/includes/job/JobQueueGroup.php
@@ -392,6 +392,10 @@ class JobQueueGroup {
                                        }
                                }
                        }
+                       // The tasks may have recycled jobs or release delayed jobs into the queue
+                       if ( isset( $tasksRun[$type] ) && !$queue->isEmpty() ) {
+                               JobQueueAggregator::singleton()->notifyQueueNonEmpty( $this->wiki, $type );
+                       }
                }
 
                $wgMemc->merge( $key, function ( $cache, $key, $lastRuns ) use ( $tasksRun ) {