Make sure to catch php errors during job execution
Signed-off-by: Daniel Kesselberg <mail@danielkesselberg.de>
This commit is contained in:
parent
ac9f06030b
commit
73fa8630c4
2 changed files with 22 additions and 1 deletions
|
@ -63,7 +63,7 @@ abstract class Job implements IJob {
|
||||||
|
|
||||||
$logger->debug('Finished ' . get_class($this) . ' job with ID ' . $this->getId() . ' in ' . $timeTaken . ' seconds', ['app' => 'cron']);
|
$logger->debug('Finished ' . get_class($this) . ' job with ID ' . $this->getId() . ' in ' . $timeTaken . ' seconds', ['app' => 'cron']);
|
||||||
$jobList->setExecutionTime($this, $timeTaken);
|
$jobList->setExecutionTime($this, $timeTaken);
|
||||||
} catch (\Exception $e) {
|
} catch (\Throwable $e) {
|
||||||
if ($logger) {
|
if ($logger) {
|
||||||
$logger->logException($e, [
|
$logger->logException($e, [
|
||||||
'app' => 'core',
|
'app' => 'core',
|
||||||
|
|
|
@ -39,6 +39,27 @@ class JobTest extends \Test\TestCase {
|
||||||
$this->assertCount(1, $jobList->getAll());
|
$this->assertCount(1, $jobList->getAll());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public function testRemoveAfterError() {
|
||||||
|
$jobList = new DummyJobList();
|
||||||
|
$job = new TestJob($this, function () {
|
||||||
|
$test = null;
|
||||||
|
$test->someMethod();
|
||||||
|
});
|
||||||
|
$jobList->add($job);
|
||||||
|
|
||||||
|
$logger = $this->getMockBuilder(ILogger::class)
|
||||||
|
->disableOriginalConstructor()
|
||||||
|
->getMock();
|
||||||
|
$logger->expects($this->once())
|
||||||
|
->method('logException')
|
||||||
|
->with($this->isInstanceOf(\Throwable::class));
|
||||||
|
|
||||||
|
$this->assertCount(1, $jobList->getAll());
|
||||||
|
$job->execute($jobList, $logger);
|
||||||
|
$this->assertTrue($this->run);
|
||||||
|
$this->assertCount(1, $jobList->getAll());
|
||||||
|
}
|
||||||
|
|
||||||
public function markRun() {
|
public function markRun() {
|
||||||
$this->run = true;
|
$this->run = true;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue