Changed: Refresh child entity when checking root job status

Author: aigarszuika

CalculateRootJobStatusProcessor.php

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

CalculateRootJobStatusService.php

@@ -69,6 +69,7 @@ protected function calculateRootJobStatus(array $jobs)
         $success = 0;
 
         foreach ($jobs as $job) {
+            $this->jobStorage->refreshedJobEntity($job);
             switch ($job->getStatus()) {
                 case Job::STATUS_NEW:
                     $new++;

Doctrine/JobStorage.php

@@ -179,9 +179,12 @@ public function saveJob(Job $job, \Closure $lockCallback = null)
         }
     }
 
-    public function clearJobCache()
+    /**
+     * @param Job $job
+     */
+    public function refreshedJobEntity($job)
     {
-        $this->getEntityManager()->clear($this->entityClass);
+        $this->getEntityManager()->refresh($job);
     }
 
     /**