File manager - Edit - /home/autoph/public_html/projects/vendor/laravel/framework/src/Illuminate/Queue/Console/RetryBatchCommand.php
Back
<?php namespace Illuminate\Queue\Console; use Illuminate\Bus\BatchRepository; use Illuminate\Console\Command; use Illuminate\Contracts\Console\Isolatable; use Symfony\Component\Console\Attribute\AsCommand; #[AsCommand(name: 'queue:retry-batch')] class RetryBatchCommand extends Command implements Isolatable { /** * The console command signature. * * @var string */ protected $signature = 'queue:retry-batch {id?* : The ID of the batch whose failed jobs should be retried}'; /** * The console command description. * * @var string */ protected $description = 'Retry the failed jobs for a batch'; /** * Execute the console command. * * @return int|null */ public function handle() { $batchesFound = count($ids = $this->getBatchJobIds()) > 0; if ($batchesFound) { $this->components->info('Pushing failed batch jobs back onto the queue.'); } foreach ($ids as $batchId) { $batch = $this->laravel[BatchRepository::class]->find($batchId); if (! $batch) { $this->components->error("Unable to find a batch with ID [{$batchId}]."); } elseif (empty($batch->failedJobIds)) { $this->components->error('The given batch does not contain any failed jobs.'); } $this->components->info("Pushing failed queue jobs of the batch [$batchId] back onto the queue."); foreach ($batch->failedJobIds as $failedJobId) { $this->components->task( $failedJobId, fn () => $this->callSilent('queue:retry', ['id' => $failedJobId]) == 0 ); } $this->newLine(); } } /** * Get the custom mutex name for an isolated command. * * @return string */ public function isolatableId() { return $this->argument('id'); } /** * Get the batch IDs to be retried. * * @return array */ protected function getBatchJobIds() { $ids = (array) $this->argument('id'); return array_values(array_filter(array_unique($ids))); } }
| ver. 1.4 |
.
| PHP 8.1.32 | Generation time: 0.17 |
proxy
|
phpinfo
|
Settings