then:
        thrown(NoAvailableWorkerLeaseException)

        when:
        def result = registry.runAsWorkerThread(action)

        then:
        result == "result"

        and:
        !registry.workerThread

        when:
        registry.currentWorkerLease

        then:
        thrown(NoAvailableWorkerLeaseException)

        cleanup:
        registry?.stop()

    public WorkerLease getCurrentWorkerLease() {
        List<? extends WorkerLease> operations = workerLeaseLockRegistry.getResourceLocksByCurrentThread();
        if (operations.isEmpty()) {
            throw new NoAvailableWorkerLeaseException("No worker lease associated with the current thread");
        }
        if (operations.size() != 1) {
            throw new IllegalStateException("Expected the current thread to hold a single worker lease");