h2o-py/h2o/utils/progressbar.py
def _estimate_progress_completion_time(self, now):
        """
        Estimate the moment when the underlying process is expected to reach completion.

        This function should only return future times. Also this function is not allowed to return time moments less
        than self._next_poll_time if the actual progress is below 100% (this is because we won't know that the
        process have finished until we poll the external progress function).
        """
        assert self._next_poll_time >= now
        tlast, wlast = self._progress_data[-1]
        # If reached 100%, make sure that we finish as soon as possible, but maybe not immediately
        if wlast == self._maxval:
            current_completion_time = (1 - self._x0) / self._v0 + self._t0
            return clamp(current_completion_time, now, now + self.FINISH_DELAY)

        # Calculate the approximate speed of the raw progress based on recent data
        tacc, wacc = 0, 0
        factor = self.GAMMA
        for t, x in self._progress_data[-2::-1]:
            tacc += factor * (tlast - t)
            wacc += factor * (wlast - x)
            factor *= self.GAMMA
            if factor < 1e-2: break

        # If there was no progress at all, then just assume it's 5 minutes from now
        if wacc == 0: return now + 300

        # Estimate the completion time assuming linear progress
        t_estimate = tlast + tacc * (self._maxval - wlast) / wacc

        # Adjust the estimate if it looks like it may happen too soon
        if t_estimate <= self._next_poll_time:
            t_estimate = self._next_poll_time + self.FINISH_DELAY

        return t_estimate
def _estimate_progress_completion_time(self, now):
        assert self._next_poll_time >= now
        tlast, wlast = self._progress_data[-1]
        # If reached 100%, make sure that we finish as soon as possible, but maybe not immediately
        if wlast == self._maxval:
            current_completion_time = (1 - self._x0) / self._v0 + self._t0
            return clamp(current_completion_time, now, now + self.FINISH_DELAY)

        # Calculate the approximate speed of the raw progress based on recent data
        tacc, wacc = 0, 0
        factor = self.GAMMA
        for t, x in self._progress_data[-2::-1]:
            tacc += factor * (tlast - t)
            wacc += factor * (wlast - x)
            factor *= self.GAMMA
            if factor < 1e-2: break

        # If there was no progress at all, then just assume it's 5 minutes from now
        if wacc == 0: return now + 300

        # Estimate the completion time assuming linear progress
        t_estimate = tlast + tacc * (self._maxval - wlast) / wacc

        # Adjust the estimate if it looks like it may happen too soon
        if t_estimate <= self._next_poll_time:
            t_estimate = self._next_poll_time + self.FINISH_DELAY

        return t_estimate
def _estimate_progress_completion_time ( self , now ) : assert self . _next_poll_time >= now tlast , wlast = self . _progress_data [ - 1 ] # If reached 100%, make sure that we finish as soon as possible, but maybe not immediately if wlast == self . _maxval : current_completion_time = ( 1 - self . _x0 ) / self . _v0 + self . _t0 return clamp ( current_completion_time , now , now + self . FINISH_DELAY ) # Calculate the approximate speed of the raw progress based on recent data tacc , wacc = 0 , 0 factor = self . GAMMA for t , x in self . _progress_data [ - 2 : : - 1 ] : tacc += factor * ( tlast - t ) wacc += factor * ( wlast - x ) factor *= self . GAMMA if factor < 1e-2 : break # If there was no progress at all, then just assume it's 5 minutes from now if wacc == 0 : return now + 300 # Estimate the completion time assuming linear progress t_estimate = tlast + tacc * ( self . _maxval - wlast ) / wacc # Adjust the estimate if it looks like it may happen too soon if t_estimate <= self . _next_poll_time : t_estimate = self . _next_poll_time + self . FINISH_DELAY return t_estimate
Estimate the moment when the underlying process is expected to reach completion.

        This function should only return future times. Also this function is not allowed to return time moments less
        than self._next_poll_time if the actual progress is below 100% (this is because we won't know that the
        process have finished until we poll the external progress function).
Estimate the moment when the underlying process is expected to reach completion .