24076123284

Committed 07 Apr 2026 10:11AM UTC coverage: 89.74% (-3.3%) from 93.005%

Build # 24076123284

Build Type

push

github

Committed by

web-flow

Commit Message

[10.x] Overrides `schedule:work` command (#107)

fixes orchestral/testbench-core#395

Signed-off-by: Mior Muhammad Zaki <crynobone@gmail.com>

Coverage Stats

1 of 24 new or added lines in 2 files covered. (4.17%)

586 of 653 relevant lines covered (89.74%)

17.09 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Console/ScheduleWorkCommand.php

<?php

namespace Orchestra\Workbench\Console;

use Illuminate\Console\Application;
use Illuminate\Console\Command;
use Illuminate\Support\Carbon;
use Illuminate\Support\ProcessUtils;
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Process\Process;

use function Orchestra\Sidekick\working_path;

#[AsCommand(name: 'schedule:work')]
class ScheduleWorkCommand extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'schedule:work
        {--run-output-file= : The file to direct <info>schedule:run</info> output to}
        {--whisper : Do not output message indicating that no jobs were ready to run}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Start the schedule worker';

    /**
     * Execute the console command.
     *
     * @return never
     */
    public function handle()
    {
        $this->components->info(
            'Running scheduled tasks.',
            $this->getLaravel()->environment('local') ? OutputInterface::VERBOSITY_NORMAL : OutputInterface::VERBOSITY_VERBOSE
        );

        [$lastExecutionStartedAt, $executions] = [Carbon::now()->subMinutes(10), []];

        $command = Application::formatCommandString('schedule:run');

        if ($this->option('whisper')) {
            $command .= ' --whisper';
        }

        if ($this->option('run-output-file')) {
            $command .= ' >> '.ProcessUtils::escapeArgument($this->option('run-output-file')).' 2>&1';
        }

        while (true) {
            usleep(100 * 1000);

            if (Carbon::now()->second === 0 &&
                ! Carbon::now()->startOfMinute()->equalTo($lastExecutionStartedAt)) {
                $executions[] = $execution = Process::fromShellCommandline($command, working_path());

                $execution->start();

                $lastExecutionStartedAt = Carbon::now()->startOfMinute();
            }

            foreach ($executions as $key => $execution) {
                $output = $execution->getIncrementalOutput().
                    $execution->getIncrementalErrorOutput();

                $this->output->write(ltrim($output, "\n"));

                if (! $execution->isRunning()) {
                    unset($executions[$key]);
                }
            }
        }
    }
}

1	<?php
2
3	namespace Orchestra\Workbench\Console;
4
5	use Illuminate\Console\Application;
6	use Illuminate\Console\Command;
7	use Illuminate\Support\Carbon;
8	use Illuminate\Support\ProcessUtils;
9	use Symfony\Component\Console\Attribute\AsCommand;
10	use Symfony\Component\Console\Output\OutputInterface;
11	use Symfony\Component\Process\Process;
12
13	use function Orchestra\Sidekick\working_path;
14
15	#[AsCommand(name: 'schedule:work')]
16	class ScheduleWorkCommand extends Command
17	{
18	/**
19	* The name and signature of the console command.
20	*
21	* @var string
22	*/
23	protected $signature = 'schedule:work
24	{--run-output-file= : The file to direct <info>schedule:run</info> output to}
25	{--whisper : Do not output message indicating that no jobs were ready to run}';
26
27	/**
28	* The console command description.
29	*
30	* @var string
31	*/
32	protected $description = 'Start the schedule worker';
33
34	/**
35	* Execute the console command.
36	*
37	* @return never
38	*/
39	public function handle()
40	{
NEW 41	$this->components->info(	×
NEW 42	'Running scheduled tasks.',	×
NEW 43	$this->getLaravel()->environment('local') ? OutputInterface::VERBOSITY_NORMAL : OutputInterface::VERBOSITY_VERBOSE	×
NEW 44	);	×
45
NEW 46	[$lastExecutionStartedAt, $executions] = [Carbon::now()->subMinutes(10), []];	×
47
NEW 48	$command = Application::formatCommandString('schedule:run');	×
49
NEW 50	if ($this->option('whisper')) {	×
NEW 51	$command .= ' --whisper';	×
52	}
53
NEW 54	if ($this->option('run-output-file')) {	×
NEW 55	$command .= ' >> '.ProcessUtils::escapeArgument($this->option('run-output-file')).' 2>&1';	×
56	}
57
NEW 58	while (true) {	×
NEW 59	usleep(100 * 1000);	×
60
NEW 61	if (Carbon::now()->second === 0 &&	×
NEW 62	! Carbon::now()->startOfMinute()->equalTo($lastExecutionStartedAt)) {	×
NEW 63	$executions[] = $execution = Process::fromShellCommandline($command, working_path());	×
64
NEW 65	$execution->start();	×
66
NEW 67	$lastExecutionStartedAt = Carbon::now()->startOfMinute();	×
68	}
69
NEW 70	foreach ($executions as $key => $execution) {	×
NEW 71	$output = $execution->getIncrementalOutput().	×
NEW 72	$execution->getIncrementalErrorOutput();	×
73
NEW 74	$this->output->write(ltrim($output, "\n"));	×
75
NEW 76	if (! $execution->isRunning()) {	×
NEW 77	unset($executions[$key]);	×
78	}
79	}
80	}
81	}
82	}

orchestral / workbench / 24076123284

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous