(self)
| 4520 | self._start_timer() |
| 4521 | |
| 4522 | def _make_query_plan(self): |
| 4523 | # set the query_plan according to the load balancing policy, |
| 4524 | # or to the explicit host target if set |
| 4525 | if self._host: |
| 4526 | # returning a single value effectively disables retries |
| 4527 | self.query_plan = [self._host] |
| 4528 | else: |
| 4529 | # convert the list/generator/etc to an iterator so that subsequent |
| 4530 | # calls to send_request (which retries may do) will resume where |
| 4531 | # they last left off |
| 4532 | self.query_plan = iter(self._load_balancer.make_query_plan(self.session.keyspace, self.query)) |
| 4533 | |
| 4534 | def send_request(self, error_no_hosts=True): |
| 4535 | """ Internal """ |
no test coverage detected