(cls, connection, host, chunks, set_keyspace=False)
| 2261 | |
| 2262 | @classmethod |
| 2263 | def _send_chunks(cls, connection, host, chunks, set_keyspace=False): |
| 2264 | for ks_chunk in chunks: |
| 2265 | messages = [PrepareMessage(query=s.query_string, |
| 2266 | keyspace=s.keyspace if set_keyspace else None) |
| 2267 | for s in ks_chunk] |
| 2268 | # TODO: make this timeout configurable somehow? |
| 2269 | responses = connection.wait_for_responses(*messages, timeout=5.0, fail_on_error=False) |
| 2270 | for success, response in responses: |
| 2271 | if not success: |
| 2272 | log.debug("Got unexpected response when preparing " |
| 2273 | "statement on host %s: %r", host, response) |
| 2274 | |
| 2275 | def _prepare_all_queries(self, host): |
| 2276 | if not self._prepared_statements or not self.reprepare_on_up: |
no test coverage detected