diff --git a/cli/src/Command/Queue.php b/cli/src/Command/Queue.php index a643693..7433304 100644 --- a/cli/src/Command/Queue.php +++ b/cli/src/Command/Queue.php @@ -60,10 +60,10 @@ class Queue extends Command } $responses = $this->fastcgi->awaitResponses(); foreach ($responses as $response) { - if ((int) floor($response->getStatusCode() / 100) !== 2) { + if ($response->getError() !== '') { $this->logger->error("Error running job", [ - 'status' => $response->getStatusCode(), - 'body' => $response->getBody()->getContents(), + 'error' => $response->getError(), + 'body' => $response->getBody(), 'headers' => $response->getHeaders(), ]); $errors ++;