ClearHorizonCommand

gistfile1.txt

<?php

namespace App\Console\Commands;

use DB;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Artisan;
use Illuminate\Support\Facades\Redis;

class ClearHorizonCommand extends Command
{
    protected $signature = 'horizon:clear-all';

    public function handle(): void
    {
        Redis::connection(name: 'horizon')->client()->flushAll();
        DB::table('job_batches')->delete();
        Redis::connection()->del([config('horizon.prefix').'failed:*']);
        Redis::connection()->del([config('horizon.prefix').'failed_jobs']);

        Artisan::call('horizon:terminate');

        $this->info('Horizon cleared & restarted.');
    }
}