"""Process the Retriever Run upon error."""
        self._submit(self._update_run_single, _copy(run))
[docs]    def wait_for_futures(self) -> None:
        """Wait for the given futures to complete."""
        wait(self._futures)