Merge pull request #28 from laravel/pr7428

Handle jobs timeouts

src/Console/Commands/VaporWorkCommand.php

@@ -21,6 +21,7 @@ class VaporWorkCommand extends Command
     protected $signature = 'vapor:work
                             {message : The Base64 encoded message payload}
                             {--delay=0 : The number of seconds to delay failed jobs}
+                            {--timeout=0 : The number of seconds a child process can run}
                             {--tries=0 : Number of times to attempt a job before logging it failed}
                             {--force : Force the worker to run even in maintenance mode}';
 
@@ -167,7 +168,7 @@ protected function gatherWorkerOptions()
     {
         return new WorkerOptions(
             $this->option('delay'), $memory = 512,
-            $timeout = 0, $sleep = 0,
+            $this->option('timeout'), $sleep = 0,
             $this->option('tries'), $this->option('force'),
             $stopWhenEmpty = false
         );

src/Queue/VaporWorker.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Queue\Worker;
 use Illuminate\Queue\WorkerOptions;
+use Laravel\Vapor\VaporJobTimedOutException;
 
 class VaporWorker extends Worker
 {
@@ -17,6 +18,16 @@ class VaporWorker extends Worker
      */
     public function runVaporJob($job, $connectionName, WorkerOptions $options)
     {
+        pcntl_async_signals(true);
+
+        pcntl_signal(SIGALRM, function () use ($job) {
+            throw new VaporJobTimedOutException($job->resolveName());
+        });
+
+        pcntl_alarm(
+            max($this->timeoutForJob($job, $options), 0)
+        );
+
         return $this->runJob($job, $connectionName, $options);
     }
 }

src/Runtime/Handlers/QueueHandler.php

@@ -40,8 +40,9 @@ public function __construct()
     public function handle(array $event)
     {
         $commandOptions = trim(sprintf(
-            '--delay=%s --tries=%s %s',
+            '--delay=%s --timeout=%s --tries=%s %s',
             $_ENV['SQS_DELAY'] ?? 3,
+            $_ENV['QUEUE_TIMEOUT'] ?? 0,
             $_ENV['SQS_TRIES'] ?? 3,
             ($_ENV['SQS_FORCE'] ?? false) ? '--force' : ''
         ));

src/VaporJobTimedOutException.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace Laravel\Vapor;
+
+use Throwable;
+use Exception;
+
+class VaporJobTimedOutException extends Exception
+{
+    /**
+     * Create a new exception instance.
+     *
+     * @param string $name
+     * @param Throwable|null $previous
+     */
+    public function __construct($name, Throwable $previous = null)
+    {
+        parent::__construct($name. ' has timed out. It will be retried again.', 0, $previous);
+    }
+}