(result)
| 1567 | consistency_level=ConsistencyLevel.ONE) |
| 1568 | |
| 1569 | def process_result(result): |
| 1570 | if isinstance(result, ResultMessage): |
| 1571 | self.keyspace = keyspace |
| 1572 | callback(self, None) |
| 1573 | elif isinstance(result, InvalidRequestException): |
| 1574 | callback(self, result.to_exception()) |
| 1575 | else: |
| 1576 | callback(self, self.defunct(ConnectionException( |
| 1577 | "Problem while setting keyspace: %r" % (result,), self.endpoint))) |
| 1578 | |
| 1579 | # We've incremented self.in_flight above, so we "have permission" to |
| 1580 | # acquire a new request id |
nothing calls this directly
no test coverage detected