symbiote / silverstripe-queuedjobs

        // finally, find the list of broken jobs and send an email if there's some found

        $brokenJobs = QueuedJobDescriptor::get()->filter('JobStatus', QueuedJob::STATUS_BROKEN);

        if ($brokenJobs && $brokenJobs->count()) {

            $this->getLogger()->error(

                print_r(

                    [

                        'errno' => 0,

                        'errstr' => 'Broken jobs were found in the job queue',

                        'errfile' => __FILE__,

                        'errline' => __LINE__,

                        'errcontext' => [],

                    ],

                    true

                ),

                [

                    'file' => __FILE__,

                    'line' => __LINE__,

                ]

            );

        }

        return $stalledJobs->count();

    }

                    if ($jobDescriptor) {

                        $this->copyJobToDescriptor($job, $jobDescriptor);

                        $jobDescriptor->write();

                    } else {

                        $this->getLogger()->error(

                            print_r(

                                [

                                    'errno' => 0,

                                    'errstr' => 'Job descriptor has been set to null',

                                    'errfile' => __FILE__,

                                    'errline' => __LINE__,

                                    'errcontext' => [],

                                ],

                                true

                            ),

                            [

                                'file' => __FILE__,

                                'line' => __LINE__,

                            ]

                        );

                        $broken = true;

                    }

                }

                // a last final save. The job is complete by now