private function assertCorrectService(ContainerBuilder $container, $serviceId)
    {
        $definition = $container->findDefinition($serviceId);
        $reflection = new ReflectionClass($definition->getClass());
        if (!$reflection->implementsInterface(WorkerRunnerInterface::class)) {
            throw new InvalidArgumentException('Runner service has to implement WorkerRunnerInterface.');
        }
    }