fixes

src/Entity/TaskInterface.php

@@ -46,5 +46,12 @@ public function getStopAt(): ?DateTime;
 
     public function incNumberErrors(): TaskInterface;
 
+    /**
+     * Returns number errors by default 0.
+     */
     public function getNumberErrors(): int;
+
+    public function setParams(array $params): TaskInterface;
+
+    public function getParams(): array;
 }

src/Service/QueueService.php

@@ -10,6 +10,7 @@
 use Bupy7\Queue\Exception\UnknownTaskException;
 use Bupy7\Queue\Task\TaskInterface;
 use Bupy7\Queue\Options\ModuleOptions;
+use Exception;
 
 class QueueService
 {
@@ -45,15 +46,19 @@ public function __construct(
     public function run(): void
     {
         $entities = $this->taskRepository->findForRun($this->config->getOneTimeLimit() ?: null);
-        foreach ($entities as $entity) {
-            if (in_array($entity->getStatusId(), [
-                TaskEntityInterface::STATUS_WAIT,
-                TaskEntityInterface::STATUS_ERROR,
-            ])) {
-                $this->executeTask($entity);
+        try {
+            foreach ($entities as $entity) {
+                if (in_array($entity->getStatusId(), [
+                    TaskEntityInterface::STATUS_WAIT,
+                    TaskEntityInterface::STATUS_ERROR,
+                ])) {
+                    $this->executeTask($entity);
+                }
             }
+        } catch (Exception $e) {
+            $this->entityManager->flush();
+            throw $e;
         }
-        $this->entityManager->flush();
     }
 
     protected function executeTask(TaskEntityInterface $entity): void
@@ -64,7 +69,7 @@ protected function executeTask(TaskEntityInterface $entity): void
         /** @var TaskInterface $task */
         $task = $this->queueManager->get($entity->getName());
         $entity->setRunAt(new DateTime);
-        if ($task->execute()) {
+        if ($task->execute($entity->getParams())) {
             $entity->setStatusId(TaskEntityInterface::STATUS_OK);
         } else {
             $entity->incNumberErrors();

src/Service/TaskService.php

@@ -8,8 +8,6 @@
 
 class TaskService
 {
-    private const DEFAULT_NUMBER_ERRORS = 0;
-
     /**
      * @var EntityManagerInterface
      */
@@ -27,8 +25,8 @@ public function create(array $data, TaskInterface $task): bool
         }
         $task->setStatusId(TaskInterface::STATUS_WAIT)
             ->setCreatedAt(new DateTime)
-            ->setNumberErrors(self::DEFAULT_NUMBER_ERRORS)
-            ->setName($data['name']);
+            ->setName($data['name'])
+            ->setParams($data['params'] ?? []);
         $this->entityManager->persist($task);
         $this->entityManager->flush();
     }

src/Task/TaskInterface.php

@@ -7,5 +7,5 @@
  */
 interface TaskInterface
 {
-    public function execute(): bool;
+    public function execute(array $params): bool;
 }

test/Assert/Entity/Task.php

@@ -39,6 +39,10 @@ class Task implements TaskInterface
      * @var int
      */
     protected $numberErrors = 0;
+    /**
+     * @var array
+     */
+    protected $params = [];
 
     public function __construct()
     {
@@ -135,4 +139,15 @@ public function getNumberErrors(): int
     {
         return $this->numberErrors;
     }
+
+    public function setParams(array $params): TaskInterface
+    {
+        $this->params = $params;
+        return $this;
+    }
+
+    public function getParams(): array
+    {
+        return $this->params;
+    }
 }

test/Assert/Task/ErrorHelloTask.php

@@ -9,7 +9,7 @@
  */
 class ErrorHelloTask implements TaskInterface
 {
-    public function execute(): bool
+    public function execute(array $params): bool
     {
         return false;
     }

test/Assert/Task/SuccessHelloTask.php

@@ -9,7 +9,7 @@
  */
 class SuccessHelloTask implements TaskInterface
 {
-    public function execute(): bool
+    public function execute(array $params): bool
     {
         return true;
     }