return this;
        }

        public Builder withRunner(BuildOperationRunner runner) {
            this.runner = runner;
            return this;
        }

        public Builder withWorkerLeaseService(WorkerLeaseService workerLeaseService) {
            this.workerLeaseService = workerLeaseService;
            return this;
        }

        public Builder withQueueFactory(BuildOperationQueueFactory queueFactory) {

        workerLeaseService?.stop()
    }

    private createProcessor(WorkerLeaseService workerLeaseService, int maxWorkers) {
        return BuildOperationExecutorSupport.builder(maxWorkers)
            .withWorkerLeaseService(workerLeaseService)
            .build()
    }

    def "BuildOperationWorkerRegistry operation start blocks when there are no leases available, taken by BuildOperationExecutor"() {
        given:

        workerRegistry.startProjectExecution(true)
        buildOperationExecutor = BuildOperationExecutorSupport.builder(workerLimits).withWorkerLeaseService(workerRegistry).build()
        outerOperationCompletion = workerRegistry.startWorker()
        outerOperation = workerRegistry.getCurrentWorkerLease()
    }

    protected BuildOperationExecutor buildOperationExecutor = BuildOperationExecutorSupport.builder(new DefaultWorkerLimits(DefaultParallelismConfiguration.getDefaultMaxWorkerCount()))
        .withWorkerLeaseService(workerLeaseService)
        .withTimeSupplier { timeProvider.currentTime }

    def reportWithMaxThreads(int numThreads) {
        buildOperationExecutor = BuildOperationExecutorSupport.builder(numThreads)
            .withRunner(buildOperationRunner)
            .withWorkerLeaseService(workerLeaseService)
            .build()
        return new DefaultTestReport(buildOperationRunner, buildOperationExecutor)
    }

    def generatesReportWhenThereAreNoTestResults() {
        given: