From 33c8be3cd054b92cbaa2d44d4999ab4456a87868 Mon Sep 17 00:00:00 2001 From: Bibek Chaudhary Date: Mon, 24 Aug 2020 12:11:06 +0545 Subject: [PATCH] fixed exception handling of ksql --- ksql/api.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ksql/api.py b/ksql/api.py index f2f80d0..d2f0f15 100644 --- a/ksql/api.py +++ b/ksql/api.py @@ -122,7 +122,7 @@ def _request(self, endpoint, method="POST", sql_string="", stream_properties=Non raise http_error else: logging.debug("content: {}".format(content)) - raise KSQLError(e=content.get("message"), error_code=content.get("error_code")) + raise KSQLError(content.get("message"), content.get("error_code"), content.get("stackTrace")) else: return r