@@ 362-379 (lines=18) @@ | ||
359 | ||
360 | // finally, find the list of broken jobs and send an email if there's some found |
|
361 | $brokenJobs = QueuedJobDescriptor::get()->filter('JobStatus', QueuedJob::STATUS_BROKEN); |
|
362 | if ($brokenJobs && $brokenJobs->count()) { |
|
363 | $this->getLogger()->error( |
|
364 | print_r( |
|
365 | [ |
|
366 | 'errno' => 0, |
|
367 | 'errstr' => 'Broken jobs were found in the job queue', |
|
368 | 'errfile' => __FILE__, |
|
369 | 'errline' => __LINE__, |
|
370 | 'errcontext' => [], |
|
371 | ], |
|
372 | true |
|
373 | ), |
|
374 | [ |
|
375 | 'file' => __FILE__, |
|
376 | 'line' => __LINE__, |
|
377 | ] |
|
378 | ); |
|
379 | } |
|
380 | } |
|
381 | ||
382 | /** |
|
@@ 786-804 (lines=19) @@ | ||
783 | if ($jobDescriptor) { |
|
784 | $this->copyJobToDescriptor($job, $jobDescriptor); |
|
785 | $jobDescriptor->write(); |
|
786 | } else { |
|
787 | $this->getLogger()->error( |
|
788 | print_r( |
|
789 | [ |
|
790 | 'errno' => 0, |
|
791 | 'errstr' => 'Job descriptor has been set to null', |
|
792 | 'errfile' => __FILE__, |
|
793 | 'errline' => __LINE__, |
|
794 | 'errcontext' => [], |
|
795 | ], |
|
796 | true |
|
797 | ), |
|
798 | [ |
|
799 | 'file' => __FILE__, |
|
800 | 'line' => __LINE__, |
|
801 | ] |
|
802 | ); |
|
803 | $broken = true; |
|
804 | } |
|
805 | } |
|
806 | ||
807 | // a last final save. The job is complete by now |