Page MenuHomeWickedGov Phorge
Files F6010711

manageJobs.php
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

manageJobs.php
View Options

<?php
/**
* Maintenance script that handles managing job queue admin tasks
*
* @license GPL-2.0-or-later
* @file
* @ingroup Maintenance
*/
use MediaWiki\JobQueue\Job;
use MediaWiki\JobQueue\JobQueue;
use MediaWiki\Maintenance\Maintenance;
// @codeCoverageIgnoreStart
require_once __DIR__ . '/Maintenance.php';
// @codeCoverageIgnoreEnd
/**
* Maintenance script that handles managing job queue admin tasks (re-push, delete, ...)
*
* @ingroup Maintenance
*/
class ManageJobs extends Maintenance {
public function __construct() {
parent::__construct();
$this->addDescription( 'Perform administrative tasks on a job queue' );
$this->addOption( 'type', 'Job type', true, true );
$this->addOption( 'action', 'Queue operation ("delete", "repush-abandoned")', true, true );
$this->setBatchSize( 100 );
}
public function execute() {
$type = $this->getOption( 'type' );
$action = $this->getOption( 'action' );
$group = $this->getServiceContainer()->getJobQueueGroup();
$queue = $group->get( $type );
if ( $action === 'delete' ) {
$this->delete( $queue );
} elseif ( $action === 'repush-abandoned' ) {
$this->repushAbandoned( $queue );
} else {
$this->fatalError( "Invalid action '$action'." );
}
}
private function delete( JobQueue $queue ) {
$this->output( "Queue has {$queue->getSize()} job(s); deleting...\n" );
$queue->delete();
$this->output( "Done; current size is {$queue->getSize()} job(s).\n" );
}
private function repushAbandoned( JobQueue $queue ) {
$cache = $this->getServiceContainer()->getObjectCacheFactory()->getInstance( CACHE_DB );
$key = $cache->makeGlobalKey( 'last-job-repush', $queue->getDomain(), $queue->getType() );
$now = wfTimestampNow();
$lastRepushTime = $cache->get( $key );
if ( $lastRepushTime === false ) {
$lastRepushTime = wfTimestamp( TS_MW, 1 ); // include all jobs
}
$this->output( "Last re-push time: $lastRepushTime; current time: $now\n" );
$count = 0;
$skipped = 0;
foreach ( $queue->getAllAbandonedJobs() as $job ) {
/** @var Job $job */
if ( $job instanceof Job && $job->getQueuedTimestamp() < wfTimestamp( TS_UNIX, $lastRepushTime ) ) {
++$skipped;
continue; // already re-pushed in prior round
}
$queue->push( $job );
++$count;
if ( ( $count % $this->getBatchSize() ) == 0 ) {
$queue->waitForBackups();
}
}
$cache->set( $key, $now ); // next run will ignore these jobs
$this->output( "Re-pushed $count job(s) [$skipped skipped].\n" );
}
}
// @codeCoverageIgnoreStart
$maintClass = ManageJobs::class;
require_once RUN_MAINTENANCE_IF_MAIN;
// @codeCoverageIgnoreEnd

File Metadata

Mime Type
text/x-php
Expires
Oct 4 2026, 09:46 (5 w, 2 d ago)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
cc/b3/889be6bf5d6b72a9b563409cce4a
Default Alt Text
manageJobs.php (2 KB)

Event Timeline