def METHOD_NAME(self, msg):
    # returns True if termination has been requested
    log.err(msg)
    try:
        self._backoff_engine.wait_on_failure()
    except backoff.BackoffTimeoutExceededError:
        self._backoff_engine.on_success()  # reset the timers
        if self._drain_queue_with_exception(backoff.BackoffTimeoutExceededError(msg)):
            return True
    return False