Cancel a query via /cancel_query on impalad.
(impalad, query_id)
| 59 | |
| 60 | |
| 61 | def cancel(impalad, query_id): |
| 62 | """Cancel a query via /cancel_query on impalad.""" |
| 63 | cancel_query_url = "http://{0}:{1}/cancel_query?json&query_id={2}"\ |
| 64 | .format(impalad.webserver_interface, impalad.webserver_port, query_id) |
| 65 | response = requests.post(cancel_query_url) |
| 66 | assert response.status_code == requests.codes.ok |
| 67 | response_json = json.loads(response.text) |
| 68 | assert response_json['contents'] == "Query cancellation successful" |
| 69 | |
| 70 | |
| 71 | def wait_for_state(impalad, state): |