Changed: Refresh child entity when checking root job status

aigarszuika · aigarszuika · commit c4da15e78a7c · 2021-05-26T10:09:37.000+03:00
diff --git a/pkg/job-queue/CalculateRootJobStatusProcessor.php b/pkg/job-queue/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'])) {
diff --git a/pkg/job-queue/CalculateRootJobStatusService.php b/pkg/job-queue/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++;
diff --git a/pkg/job-queue/Doctrine/JobStorage.php b/pkg/job-queue/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);
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,6 @@ public function __construct(`
`48`	`48`
`49`	`49`	`public function process(Message $message, Context $context)`
`50`	`50`	`{`
`51`		`- $this->jobStorage->clearJobCache();`
`52`	`51`	`$data = JSON::decode($message->getBody());`
`53`	`52`
`54`	`53`	`if (!isset($data['jobId'])) {`
Original file line number	Diff line number	Diff line change
`@@ -179,9 +179,12 @@ public function saveJob(Job $job, \Closure $lockCallback = null)`
`179`	`179`	`}`
`180`	`180`	`}`
`181`	`181`
`182`		`- public function clearJobCache()`
	`182`	`+ /**`
	`183`	`+ * @param Job $job`
	`184`	`+ */`
	`185`	`+ public function refreshedJobEntity($job)`
`183`	`186`	`{`
`184`		`- $this->getEntityManager()->clear($this->entityClass);`
	`187`	`+ $this->getEntityManager()->refresh($job);`
`185`	`188`	`}`
`186`	`189`
`187`	`190`	`/**`