View GitHub Repository DtcQueueBundle

Schedule Inspection
Subscribe

Code Duplication    Length = 3-5 lines in 2 locations

Doctrine/BaseJobManager.php 2 locations

@@ 234-238 (lines=5) @@
231 
                $job = $stalledJobs[$j];
232 
                /* RetryableJob $job */
233 
                $job->setStalledCount($job->getStalledCount() + 1);
234 
                if (null !== ($maxStalled = $job->getMaxStalled()) && $job->getStalledCount() >= $maxStalled) {
235 
                    $job->setStatus(RetryableJob::STATUS_MAX_STALLED);
236 
                    $objectManager->remove($job);
237 
                    continue;
238 
                }
239 
                if (null !== ($maxRetries = $job->getMaxRetries()) && $job->getRetries() >= $maxRetries) {
240 
                    $job->setStatus(RetryableJob::STATUS_MAX_RETRIES);
241 
                    $objectManager->remove($job);
@@ 275-277 (lines=3) @@
272 
                $job->setStalledCount($job->getStalledCount() + 1);
273 
                $job->setStatus(BaseJob::STATUS_ERROR);
274 
                $job->setMessage('stalled');
275 
                if (null !== ($maxStalled = $job->getMaxStalled()) && ($job->getStalledCount() >= $job->getMaxStalled())) {
276 
                    $job->setStatus(RetryableJob::STATUS_MAX_STALLED);
277 
                }
278 
                $objectManager->remove($job);
279 
                ++$countProcessed;
280 
            }