Changed: Clear Doctrine cache before calculate Root Job Status

Before determine Root Job Status Doctrine cache for Job entity must be cleared, otherwise if this root job was processed in previous request by the same enqueue, then it will falsely return old status, which will cause infinite running root jobs

Author: aigarszuika

CalculateRootJobStatusProcessor.php

@@ -48,6 +48,7 @@ public function __construct(
 
     public function process(Message $message, Context $context)
     {
+        $this->jobStorage->clearJobCache();
         $data = JSON::decode($message->getBody());
 
         if (!isset($data['jobId'])) {

Doctrine/JobStorage.php

@@ -179,6 +179,11 @@ public function saveJob(Job $job, \Closure $lockCallback = null)
         }
     }
 
+    public function clearJobCache()
+    {
+        $this->getEntityManager()->clear($this->entityClass);
+    }
+
     /**
      * @return EntityRepository
      */