def wait(self):
        """ Wait until all in progress and queued items are processed """
        self._wait_called = True
        while self.tracked_coordinator_count() > 0 or \
                self.waiting_coordinator_count() > 0:
            time.sleep(1)
            super(AsperaTransferCoordinatorController, self).wait()
        self._wait_called = False