(self, id)
| 548 | self.cancel_query(data["query_id"]) |
| 549 | |
| 550 | def cancel_query(self, id): |
| 551 | try: |
| 552 | self._request_web_page("/cancel_query", params={"query_id": id}) |
| 553 | except requests.exceptions.HTTPError as e: |
| 554 | # TODO: Handle losing the race |
| 555 | raise e |
| 556 | |
| 557 | def get_version_info(self): |
| 558 | with self.cluster.impala.cursor(impalad=self) as cursor: |