(self, operation_handle)
| 839 | return "" |
| 840 | |
| 841 | def get_log(self, operation_handle): |
| 842 | self.log_handle(operation_handle, 'getting log for operation') |
| 843 | # HS2 includes non-error log messages that we need to filter out. |
| 844 | cursor = operation_handle.get_handle() |
| 845 | lines = [line for line in cursor.get_log().split('\n') |
| 846 | if not PROGRESS_LOG_RE.match(line)] |
| 847 | return '\n'.join(lines) |
| 848 | |
| 849 | def fetch(self, sql_stmt, operation_handle, max_rows=-1, discard_results=False): |
| 850 | self.log_handle(operation_handle, 'fetching {} rows'.format( |
no test coverage detected