@@ 350-363 (lines=14) @@ | ||
347 | ||
348 | // finally, find the list of broken jobs and send an email if there's some found |
|
349 | $brokenJobs = QueuedJobDescriptor::get()->filter('JobStatus', QueuedJob::STATUS_BROKEN); |
|
350 | if ($brokenJobs && $brokenJobs->count()) { |
|
351 | $this->getLogger()->error( |
|
352 | print_r( |
|
353 | array( |
|
354 | 'errno' => 0, |
|
355 | 'errstr' => 'Broken jobs were found in the job queue', |
|
356 | 'errfile' => __FILE__, |
|
357 | 'errline' => __LINE__, |
|
358 | 'errcontext' => array() |
|
359 | ), |
|
360 | true |
|
361 | ) |
|
362 | ); |
|
363 | } |
|
364 | } |
|
365 | ||
366 | /** |
|
@@ 733-747 (lines=15) @@ | ||
730 | if ($jobDescriptor) { |
|
731 | $this->copyJobToDescriptor($job, $jobDescriptor); |
|
732 | $jobDescriptor->write(); |
|
733 | } else { |
|
734 | $this->getLogger()->error( |
|
735 | print_r( |
|
736 | array( |
|
737 | 'errno' => 0, |
|
738 | 'errstr' => 'Job descriptor has been set to null', |
|
739 | 'errfile' => __FILE__, |
|
740 | 'errline' => __LINE__, |
|
741 | 'errcontext' => array() |
|
742 | ), |
|
743 | true |
|
744 | ) |
|
745 | ); |
|
746 | $broken = true; |
|
747 | } |
|
748 | } |
|
749 | ||
750 | // a last final save. The job is complete by now |