| 1177 | |
| 1178 | |
| 1179 | class NeverRetryPolicy(RetryPolicy): |
| 1180 | def _rethrow(self, *args, **kwargs): |
| 1181 | return self.RETHROW, None |
| 1182 | |
| 1183 | on_read_timeout = _rethrow |
| 1184 | on_write_timeout = _rethrow |
| 1185 | on_unavailable = _rethrow |
| 1186 | |
| 1187 | |
| 1188 | ColDesc = namedtuple('ColDesc', ['ks', 'table', 'col']) |