Append the retried query link if the original query has been retried
(self, get_log_result)
| 416 | return self._get_warn_or_error_log(last_query_handle, False) |
| 417 | |
| 418 | def _append_retried_query_link(self, get_log_result): |
| 419 | """Append the retried query link if the original query has been retried""" |
| 420 | if self.webserver_address: |
| 421 | query_id_search = re.search("Query has been retried using query id: (.*)\n", |
| 422 | get_log_result) |
| 423 | if query_id_search and len(query_id_search.groups()) >= 1: |
| 424 | retried_query_id = query_id_search.group(1) |
| 425 | get_log_result += "Retried query link: %s" % \ |
| 426 | self.get_query_link(retried_query_id) |
| 427 | return get_log_result |
| 428 | |
| 429 | def _get_http_transport(self, connect_timeout_ms): |
| 430 | """Creates a transport with HTTP as the base.""" |
no test coverage detected