Fix count

Author: jeremycr

src/Entity/Job.php

@@ -56,6 +56,8 @@ class Job
 
     private ?int $count = 0;
 
+    private ?int $exceptionCount = 0;
+
     private ?array $exceptions = null;
 
     private ?\DateTimeInterface $startTime = null;
@@ -94,6 +96,7 @@ public static function createFromArray(array $datas)
         $job->setRequestedDate($datas['requested_date']);
         $job->setScheduledDataflowId($datas['scheduled_dataflow_id'] === null ? null : (int) $datas['scheduled_dataflow_id']);
         $job->setCount($datas['count'] === null ? null : (int) $datas['count']);
+        $job->setExceptionCount($datas['exception_count']);
         $job->setExceptions($datas['exceptions']);
         $job->setStartTime($datas['start_time']);
         $job->setEndTime($datas['end_time']);
@@ -112,6 +115,7 @@ public function toArray(): array
             'requested_date' => $this->getRequestedDate(),
             'scheduled_dataflow_id' => $this->getScheduledDataflowId(),
             'count' => $this->getCount(),
+            'exception_count' => $this->getExceptionCount(),
             'exceptions' => $this->getExceptions(),
             'start_time' => $this->getStartTime(),
             'end_time' => $this->getEndTime(),
@@ -214,6 +218,18 @@ public function setCount(?int $count): self
         return $this;
     }
 
+    public function getExceptionCount(): ?int
+    {
+        return $this->exceptionCount;
+    }
+
+    public function setExceptionCount(?int $exceptionCount): self
+    {
+        $this->exceptionCount = $exceptionCount;
+
+        return $this;
+    }
+
     public function getExceptions(): ?array
     {
         return $this->exceptions;

src/Processor/JobProcessor.php

@@ -45,7 +45,7 @@ public function process(Job $job): void
             $dataflowType->setRepository($this->repository);
         }
 
-        $handler = new StreamHandler(tempnam(sys_get_temp_dir(), 'dataflow_'));
+        $handler = new StreamHandler(tempnam(sys_get_temp_dir(), 'dataflow_'), fileOpenMode: 'w+');
         $handler->setFormatter(new LineFormatter(self::FORMAT));
 
         $loggers = [new Logger('dataflow_internal', [$bufferHandler = $handler])];
@@ -78,6 +78,7 @@ private function afterProcessing(Job $job, Result $result, StreamHandler $stream
             ->setEndTime($result->getEndTime())
             ->setStatus(Job::STATUS_COMPLETED)
             ->setCount($result->getSuccessCount())
+            ->setExceptionCount($result->getErrorCount())
         ;
 
         if (!$this->exceptionHandler instanceof NullExceptionHandler) {