Function assert_kill_error

tests/util/cancel_util.py:84–91

(client, error_msg, query_id=None, sql=None, user=None)

def assert_kill_error(client, error_msg, query_id=None, sql=None, user=None):
  if sql is None:
    sql = "KILL QUERY '{0}'".format(query_id)
  try:
    client.execute(sql, user=user)
    assert False, "Failed to catch the exception."
  except Exception as exc:
    assert error_msg_startswith(str(exc), error_msg)


class FetchingThread(threading.Thread):