def METHOD_NAME(self, timeout_sec=600):
    """Wait no more than timeout_sec for all worker threads to finish.
    raise TimeoutException if all worker threads do not finish within timeout_sec
    """
    super().METHOD_NAME(timeout_sec)
    self._propagate_exceptions()