diff options
Diffstat (limited to 'maintenance/showJobs.php')
| -rw-r--r-- | maintenance/showJobs.php | 20 |
1 files changed, 16 insertions, 4 deletions
diff --git a/maintenance/showJobs.php b/maintenance/showJobs.php index b8dc5548..9e9ad327 100644 --- a/maintenance/showJobs.php +++ b/maintenance/showJobs.php @@ -38,16 +38,19 @@ class ShowJobs extends Maintenance { parent::__construct(); $this->mDescription = "Show number of jobs waiting in master database"; $this->addOption( 'group', 'Show number of jobs per job type' ); - $this->addOption( - 'list', - 'Show a complete list of all jobs in a machine-readable format, instead of statistics' - ); + $this->addOption( 'list', + 'Show a list of all jobs in a machine-readable format, instead of statistics' ); + $this->addOption( 'type', 'Only show/count jobs of a given type', false, true ); } public function execute() { + $filterType = $this->getOption( 'type', '' ); $group = JobQueueGroup::singleton(); if ( $this->hasOption( 'list' ) ) { foreach ( $group->getQueueTypes() as $type ) { + if ( $filterType != '' && $type != $filterType ) { + continue; + } $queue = $group->get( $type ); foreach ( $queue->getAllQueuedJobs() as $job ) { $this->output( $job->toString() . " status=unclaimed\n" ); @@ -55,9 +58,15 @@ class ShowJobs extends Maintenance { foreach ( $queue->getAllDelayedJobs() as $job ) { $this->output( $job->toString() . " status=delayed\n" ); } + foreach ( $queue->getAllAbandonedJobs() as $job ) { + $this->output( $job->toString() . " status=abandoned\n" ); + } } } elseif ( $this->hasOption( 'group' ) ) { foreach ( $group->getQueueTypes() as $type ) { + if ( $filterType != '' && $type != $filterType ) { + continue; + } $queue = $group->get( $type ); $delayed = $queue->getDelayedCount(); $pending = $queue->getSize(); @@ -75,6 +84,9 @@ class ShowJobs extends Maintenance { } else { $count = 0; foreach ( $group->getQueueTypes() as $type ) { + if ( $filterType != '' && $type != $filterType ) { + continue; + } $count += $group->get( $type )->getSize(); } $this->output( "$count\n" ); |