(self)
| 642 | assert len(result) == 0 |
| 643 | |
| 644 | def test_session_flush_modes(self): |
| 645 | self.client.new_session(flush_mode=kudu.FLUSH_MANUAL) |
| 646 | self.client.new_session(flush_mode=kudu.FLUSH_AUTO_SYNC) |
| 647 | self.client.new_session(flush_mode=kudu.FLUSH_AUTO_BACKGROUND) |
| 648 | |
| 649 | self.client.new_session(flush_mode='manual') |
| 650 | self.client.new_session(flush_mode='sync') |
| 651 | self.client.new_session(flush_mode='background') |
| 652 | |
| 653 | flush_mode = 'foo' |
| 654 | error_msg = 'Invalid flush mode: {0}'.format(flush_mode) |
| 655 | with self.assertRaisesRegex(ValueError, error_msg): |
| 656 | self.client.new_session(flush_mode=flush_mode) |
| 657 | |
| 658 | def test_session_mutation_buffer_settings(self): |
| 659 | self.client.new_session(flush_mode=kudu.FLUSH_AUTO_BACKGROUND, |
nothing calls this directly
no test coverage detected