Merge pull request #151 from xav-developer/fix/stuck-tasks

Tasks were stuck in case of an error, the "release" method did not return them to the queue.

Author: butschster

CHANGELOG.md

@@ -6,6 +6,8 @@ The format is based on [Keep a Changelog][keepachangelog] and this project adher
 
 ### Fixed
 
+- Tasks were stuck in case of an error, the "release" method did not return them to the queue.
+- The "calculateBackoff" method incorrectly took the index "$job->attempts()"
 - The "withHeader" method of the "\Spiral\RoadRunner\Jobs\Task\WritableHeadersInterface" interface expects the type "string|iterable", "int" is passed
 
 ## v5.12.0

src/Queue/QueueWorker.php

@@ -187,8 +187,7 @@ protected function failJob(RoadRunnerJob $job, \Throwable $e): void
     protected function maxAttemptsExceededException(RoadRunnerJob $job): MaxAttemptsExceededException
     {
         return new MaxAttemptsExceededException(
-            $job->resolveName(
-            ) . ' has been attempted too many times or run too long. The job may have previously timed out.',
+            $job->resolveName() . ' has been attempted too many times or run too long. The job may have previously timed out.',
         );
     }
 
@@ -267,9 +266,9 @@ protected function calculateBackoff(RoadRunnerJob $job, WorkerOptions $options):
             ',',
             \method_exists($job, 'backoff') && !\is_null($job->backoff())
                 ? $job->backoff()
-                : $options->backoff,
+                : (string) $options->backoff,
         );
 
-        return (int) ($backoff[$job->attempts() - 1] ?? last($backoff));
+        return (int) ($backoff[$job->attempts()] ?? last($backoff));
     }
 }

src/Queue/RoadRunnerJob.php

@@ -48,6 +48,18 @@ public function fire(): void
         $this->task->complete();
     }
 
+    public function release($delay = 0): void
+    {
+        $attempts = $this->attempts();
+
+        $this->task
+            ->withDelay($delay)
+            ->withHeader('attempts', (string) ++$attempts)
+            ->requeue('release');
+
+        parent::release($delay);
+    }
+
     protected function failed($e): void
     {
         $attempts = $this->attempts();