@@ 740-754 (lines=15) @@ | ||
737 | if ($jobDescriptor) { |
|
738 | $this->copyJobToDescriptor($job, $jobDescriptor); |
|
739 | $jobDescriptor->write(); |
|
740 | } else { |
|
741 | $this->getLogger()->error( |
|
742 | print_r( |
|
743 | array( |
|
744 | 'errno' => 0, |
|
745 | 'errstr' => 'Job descriptor has been set to null', |
|
746 | 'errfile' => __FILE__, |
|
747 | 'errline' => __LINE__, |
|
748 | 'errcontext' => array() |
|
749 | ), |
|
750 | true |
|
751 | ) |
|
752 | ); |
|
753 | $broken = true; |
|
754 | } |
|
755 | } |
|
756 | ||
757 | // a last final save. The job is complete by now |
|
@@ 361-374 (lines=14) @@ | ||
358 | ||
359 | // finally, find the list of broken jobs and send an email if there's some found |
|
360 | $brokenJobs = QueuedJobDescriptor::get()->filter('JobStatus', QueuedJob::STATUS_BROKEN); |
|
361 | if ($brokenJobs && $brokenJobs->count()) { |
|
362 | $this->getLogger()->error( |
|
363 | print_r( |
|
364 | array( |
|
365 | 'errno' => 0, |
|
366 | 'errstr' => 'Broken jobs were found in the job queue', |
|
367 | 'errfile' => __FILE__, |
|
368 | 'errline' => __LINE__, |
|
369 | 'errcontext' => array() |
|
370 | ), |
|
371 | true |
|
372 | ) |
|
373 | ); |
|
374 | } |
|
375 | } |
|
376 | ||
377 | /** |