| @@ 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 | /** |
|
| @@ 735-749 (lines=15) @@ | ||
| 732 | if ($jobDescriptor) { |
|
| 733 | $this->copyJobToDescriptor($job, $jobDescriptor); |
|
| 734 | $jobDescriptor->write(); |
|
| 735 | } else { |
|
| 736 | $this->getLogger()->error( |
|
| 737 | print_r( |
|
| 738 | array( |
|
| 739 | 'errno' => 0, |
|
| 740 | 'errstr' => 'Job descriptor has been set to null', |
|
| 741 | 'errfile' => __FILE__, |
|
| 742 | 'errline' => __LINE__, |
|
| 743 | 'errcontext' => array() |
|
| 744 | ), |
|
| 745 | true |
|
| 746 | ) |
|
| 747 | ); |
|
| 748 | $broken = true; |
|
| 749 | } |
|
| 750 | } |
|
| 751 | ||
| 752 | // a last final save. The job is complete by now |
|