|
|
|
|
@ -68,10 +68,9 @@ class MigrateBackgroundImages extends QueuedJob {
|
|
|
|
|
$this->logger = $logger;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
protected function run($argument): void {
|
|
|
|
|
if (!isset($argument['stage'])) {
|
|
|
|
|
// not executed in 25.0.0?!
|
|
|
|
|
$argument['stage'] = self::STAGE_PREPARE;
|
|
|
|
|
protected function run(mixed $argument): void {
|
|
|
|
|
if (!is_array($argument) || !isset($argument['stage'])) {
|
|
|
|
|
throw new \Exception('Job '.self::class.' called with wrong argument');
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
switch ($argument['stage']) {
|
|
|
|
|
@ -99,10 +98,10 @@ class MigrateBackgroundImages extends QueuedJob {
|
|
|
|
|
$userIds = $result->fetchAll(\PDO::FETCH_COLUMN);
|
|
|
|
|
$this->storeUserIdsToProcess($userIds);
|
|
|
|
|
} catch (\Throwable $t) {
|
|
|
|
|
$this->jobList->add(self::class, self::STAGE_PREPARE);
|
|
|
|
|
$this->jobList->add(self::class, ['stage' => self::STAGE_PREPARE]);
|
|
|
|
|
throw $t;
|
|
|
|
|
}
|
|
|
|
|
$this->jobList->add(self::class, self::STAGE_EXECUTE);
|
|
|
|
|
$this->jobList->add(self::class, ['stage' => self::STAGE_EXECUTE]);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|