diff --git a/src/Command/WorkerCommand.php b/src/Command/WorkerCommand.php index b3b729b3d4..08dc63d90d 100644 --- a/src/Command/WorkerCommand.php +++ b/src/Command/WorkerCommand.php @@ -133,11 +133,11 @@ protected function execute(InputInterface $input, OutputInterface $output): int $analysedFiles = array_fill_keys($analysedFiles, true); $tcpConector = new TcpConnector($loop); - $tcpConector->connect(sprintf('127.0.0.1:%d', $port))->done(function (ConnectionInterface $connection) use ($container, $identifier, $analysedFiles, $tmpFile, $insteadOfFile): void { + $tcpConector->connect(sprintf('127.0.0.1:%d', $port))->done(function (ConnectionInterface $connection) use ($container, $identifier, $output, $analysedFiles, $tmpFile, $insteadOfFile): void { $out = new Encoder($connection); $in = new Decoder($connection, true, 512, 0, $container->getParameter('parallel')['buffer']); $out->write(['action' => 'hello', 'identifier' => $identifier]); - $this->runWorker($container, $out, $in, $analysedFiles, $tmpFile, $insteadOfFile); + $this->runWorker($container, $out, $in, $output, $analysedFiles, $tmpFile, $insteadOfFile); }); $loop->run(); @@ -149,6 +149,7 @@ protected function execute(InputInterface $input, OutputInterface $output): int * @param Container $container * @param WritableStreamInterface $out * @param ReadableStreamInterface $in + * @param OutputInterface $output * @param array $analysedFiles * @param string|null $tmpFile * @param string|null $insteadOfFile @@ -157,12 +158,14 @@ private function runWorker( Container $container, WritableStreamInterface $out, ReadableStreamInterface $in, + OutputInterface $output, array $analysedFiles, ?string $tmpFile, ?string $insteadOfFile ): void { - $handleError = static function (\Throwable $error) use ($out): void { + $handleError = static function (\Throwable $error) use ($out, $output): void { + $output->writeln(sprintf('Error: %s', $error->getMessage())); $out->write([ 'action' => 'result', 'result' => [