def resubmit(self, req, keyspace, req_d, retries):
        self.log('resubmitting %s request' % (req.method,))
        self.pushRequest_really(req, keyspace, req_d, retries)
        try:
            self.request_queue.pending.remove((req, keyspace, req_d, retries))
        except ValueError:
            # it's already been scooped up
            pass
        else:
            self.request_queue.pending.insert(0, (req, keyspace, req_d, retries))
Push this request to the front of the line, just to be a jerk.
dataset/ETHPy150Open driftx/Telephus/telephus/pool.py/CassandraClusterPool.resubmit