(self, reuse_connection, consistency_level, host)
| 4956 | self._errors[host] = exception_from_response(response) |
| 4957 | |
| 4958 | def _retry(self, reuse_connection, consistency_level, host): |
| 4959 | if self._final_exception: |
| 4960 | # the connection probably broke while we were waiting |
| 4961 | # to retry the operation |
| 4962 | return |
| 4963 | |
| 4964 | if self._metrics is not None: |
| 4965 | self._metrics.on_retry() |
| 4966 | if consistency_level is not None: |
| 4967 | self.message.consistency_level = consistency_level |
| 4968 | |
| 4969 | # don't retry on the event loop thread |
| 4970 | self.session.submit(self._retry_task, reuse_connection, host) |
| 4971 | |
| 4972 | def _retry_task(self, reuse_connection, host): |
| 4973 | if self._final_exception: |
no test coverage detected