diff --git a/src/Processor/JobProcessor.php b/src/Processor/JobProcessor.php index 05f309d..f44754b 100644 --- a/src/Processor/JobProcessor.php +++ b/src/Processor/JobProcessor.php @@ -86,11 +86,14 @@ private function afterProcessing(Job $job, Result $result, StreamHandler $stream $job->setStreamExceptions($streamHandler->getStream()); } else { $stream = $streamHandler->getStream(); - rewind($stream); $exceptions = []; - while ($line = fgets($stream)) { - $exceptions[] = $line; + if ($stream !== null) { + rewind($stream); + while ($line = fgets($stream)) { + $exceptions[] = $line; + } } + $job->setExceptions($exceptions); $streamHandler->reset(); }