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