| @@ 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 |
|