symbiote / silverstripe-queuedjobs

                        );

                        break;

                    }

                    if ($jobDescriptor->JobStatus != QueuedJob::STATUS_RUN) {

                        // we've been paused by something, so we'll just exit

                        $job->addMessage(_t(

                            __CLASS__ . '.JOB_PAUSED',

                            'Job paused at {time}',

                            ['time' => DBDatetime::now()->Rfc2822()]

                        ));

                        $broken = true;

                    }

                    if (!$broken) {

                        // Inject real-time log handler

                            $stallCount++;

                        }

                        if ($stallCount > static::config()->get('stall_threshold')) {

                            $broken = true;

                            $job->addMessage(

                                _t(

                                    __CLASS__ . '.JOB_STALLED',

                                    'Job stalled after {attempts} attempts - please check',

                                    ['attempts' => $stallCount]

                                )

                            );

                            $jobDescriptor->JobStatus = QueuedJob::STATUS_BROKEN;

                        }

                        // now we'll be good and check our memory usage. If it is too high, we'll set the job to

                        // a 'Waiting' state, and let the next processing run pick up the job.