@routing_params
    def _route(self, attr, args, kwargs, **fkwargs):
        now = time.time()

        for i in xrange(len(self.cluster)):
            db_num = self._hosts_cycler.next()

            marked_down_at = self._down_connections.get(db_num, False)

            if not marked_down_at or (now <= marked_down_at + self.retry_timeout):
                return [db_num]
        else:
            raise self.HostListExhausted()
dataset/ETHPy150Open disqus/nydus/nydus/db/routers/base.py/RoundRobinRouter._route/swapped operands of `<=`