X-Git-Url: https://git.cyclocoop.org/?a=blobdiff_plain;f=maintenance%2FshowJobs.php;h=e054a364da0464384291951c415b01c5894b23ed;hb=052f1fcf308c7fabdaf0b177a776a1fe795c2789;hp=322a8497634f4bc9a9cc4e4613451b2d7d6c7560;hpb=6f3a0951d4f343d98d9b349d021dc550fd399cc4;p=lhc%2Fweb%2Fwiklou.git diff --git a/maintenance/showJobs.php b/maintenance/showJobs.php index 322a849763..e054a364da 100644 --- a/maintenance/showJobs.php +++ b/maintenance/showJobs.php @@ -38,11 +38,22 @@ 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' ); } public function execute() { $group = JobQueueGroup::singleton(); - if ( $this->hasOption( 'group' ) ) { + if ( $this->hasOption( 'list' ) ) { + foreach ( $group->getQueueTypes() as $type ) { + $queue = $group->get( $type ); + foreach ( $queue->getAllQueuedJobs() as $job ) { + $this->output( $job->toString() . " status=unclaimed\n" ); + } + foreach ( $queue->getAllDelayedJobs() as $job ) { + $this->output( $job->toString() . " status=delayed\n" ); + } + } + } elseif ( $this->hasOption( 'group' ) ) { foreach ( $group->getQueueTypes() as $type ) { $queue = $group->get( $type ); $pending = $queue->getSize();