def _get_command_buffer(self, host_id, command_name):
        """Returns the command buffer for the given command and arguments."""
        buf = self._cb_poll.get(host_id)
        if buf is not None:
            return buf

        if self._max_concurrency is not None:
            while self._max_concurrency >= len(self._cb_poll):
                self.join(timeout=1.0)

        connection = self.connection_pool.get_connection(
            command_name, shard_hint=host_id)
        buf = CommandBuffer(host_id, connection, self.auto_batch)
        self._cb_poll.register(host_id, buf)
        return buf
dataset/ETHPy150Open getsentry/rb/rb/clients.py/MappingClient._get_command_buffer/swapped operands of `>=`