@routing_params
    def _pre_routing(self, attr, args, kwargs, retry_for=None, **fkwargs):
        self._get_db_attempts += 1

        if self._get_db_attempts > self.attempt_reconnect_threshold:
            self.check_down_connections()

        if retry_for is not None:
            self.mark_connection_down(retry_for)

        return args, kwargs
dataset/ETHPy150Open disqus/nydus/nydus/db/routers/base.py/RoundRobinRouter._pre_routing/original