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 ++;