X-Git-Url: https://git.cyclocoop.org/?a=blobdiff_plain;f=maintenance%2FshowJobs.php;h=e054a364da0464384291951c415b01c5894b23ed;hb=052f1fcf308c7fabdaf0b177a776a1fe795c2789;hp=de078d835f34039015cfb7492a30bd8cce1485b7;hpb=c8b2ad0c98ad36908b329ca1d8f408dec86bbf31;p=lhc%2Fweb%2Fwiklou.git diff --git a/maintenance/showJobs.php b/maintenance/showJobs.php index de078d835f..e054a364da 100644 --- a/maintenance/showJobs.php +++ b/maintenance/showJobs.php @@ -25,7 +25,7 @@ * @author Antoine Musso */ -require_once( __DIR__ . '/Maintenance.php' ); +require_once __DIR__ . '/Maintenance.php'; /** * Maintenance script that reports the number of jobs currently waiting @@ -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();