Skip to content

Commit 8d531e3

Browse files
committed
Fix stream reading
1 parent eba73ea commit 8d531e3

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

src/Processor/JobProcessor.php

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,13 @@ private function afterProcessing(Job $job, Result $result, StreamHandler $stream
8585
$this->exceptionHandler->save($job->getId(), $streamHandler->getStream());
8686
$job->setStreamExceptions($streamHandler->getStream());
8787
} else {
88-
$job->setExceptions(json_decode(stream_get_contents($streamHandler->getStream()), true));
88+
$stream = $streamHandler->getStream();
89+
rewind($stream);
90+
$exceptions = [];
91+
while ($line = fgets($stream)) {
92+
$exceptions[] = $line;
93+
}
94+
$job->setExceptions($exceptions);
8995
$streamHandler->reset();
9096
}
9197

0 commit comments

Comments
 (0)