Process completed with exit code 2.

Escaped Mutant for Mutator "UnwrapStrReplace": @@ @@ } public function values(Values $values): void { - $values->registry->add('deployments', array_map(static fn(Worker $worker): array => ['name' => 'queue-worker-' . str_replace('.', '-', $worker->queue) . '-' . ($worker->friendlyName !== '' ? $worker->friendlyName : $worker->hash), 'command' => 'mammatus-queue', 'arguments' => [$worker->hash], 'addOns' => $worker->addOns], $this->type === false ? [...$this->workers()] : array_filter([...$this->workers()], fn(Worker $worker): bool => $worker->type === $this->type))); + $values->registry->add('deployments', array_map(static fn(Worker $worker): array => ['name' => 'queue-worker-' . $worker->queue . '-' . ($worker->friendlyName !== '' ? $worker->friendlyName : $worker->hash), 'command' => 'mammatus-queue', 'arguments' => [$worker->hash], 'addOns' => $worker->addOns], $this->type === false ? [...$this->workers()] : array_filter([...$this->workers()], fn(Worker $worker): bool => $worker->type === $this->type))); } }

Escaped Mutant for Mutator "Continue_": @@ @@ $message = $consumer->receiveNoWait(); if (!$message instanceof Message) { await(sleep(1)); - continue; + break; } $this->handleMessage($message, $consumer, $worker, $workerInstance, $baseLogger); await(futurePromise());

Escaped Mutant for Mutator "IncrementInteger": @@ @@ while ($this->running) { $message = $consumer->receiveNoWait(); if (!$message instanceof Message) { - await(sleep(1)); + await(sleep(2)); continue; } $this->handleMessage($message, $consumer, $worker, $workerInstance, $baseLogger);

Escaped Mutant for Mutator "DecrementInteger": @@ @@ while ($this->running) { $message = $consumer->receiveNoWait(); if (!$message instanceof Message) { - await(sleep(1)); + await(sleep(0)); continue; } $this->handleMessage($message, $consumer, $worker, $workerInstance, $baseLogger);

Escaped Mutant for Mutator "IncrementInteger": @@ @@ } private function consume(Worker $worker, WorkerContract $workerInstance, LoggerInterface $baseLogger): true { - await(sleep(1)); + await(sleep(2)); $consumer = $this->context->createConsumer(new Queue($worker->queue)); while ($this->running) { $message = $consumer->receiveNoWait();

Escaped Mutant for Mutator "IncrementInteger": @@ @@ $this->logger->error('Worker errored: ' . $throwable->getMessage(), ['exception' => $throwable]); $exitCode = ExitCode::Failure; } - await(sleep(3)); + await(sleep(4)); return $exitCode; } }

Escaped Mutant for Mutator "FunctionCallRemoval": @@ @@ $this->logger->error('Worker errored: ' . $throwable->getMessage(), ['exception' => $throwable]); $exitCode = ExitCode::Failure; } - await(sleep(3)); + return $exitCode; } }

Escaped Mutant for Mutator "DecrementInteger": @@ @@ $this->logger->error('Worker errored: ' . $throwable->getMessage(), ['exception' => $throwable]); $exitCode = ExitCode::Failure; } - await(sleep(3)); + await(sleep(2)); return $exitCode; } }

Escaped Mutant for Mutator "FunctionCallRemoval": @@ @@ } $this->promises[] = $this->consumer->setupConsumer($worker); } - await(all($this->promises)); + $exitCode = ExitCode::Success; } catch (Throwable $throwable) { $this->logger->error('Worker errored: ' . $throwable->getMessage(), ['exception' => $throwable]);