class DefaultAsyncWorkTrackerTest extends ConcurrentSpec {
    WorkerLeaseService workerLeaseService = new TestWorkerLeaseService()
    AsyncWorkTracker asyncWorkTracker = new DefaultAsyncWorkTracker(workerLeaseService)

    def "can wait for async work to complete"() {
        def operation = Mock(BuildOperationRef)

        when:
        async {
            5.times { i ->