<e6>[akash]Adding Query ID in Failed Query

README.md

@@ -1,6 +1,6 @@
 # e6data Python Connector
 
-![version](https://img.shields.io/badge/version-1.0.3-blue.svg)
+![version](https://img.shields.io/badge/version-1.0.4-blue.svg)
 
 ## Introduction
 

e6xdb/server/QueryEngineService-remote

@@ -1,6 +1,6 @@
 #!/usr/bin/env python
 #
-# Autogenerated by Thrift Compiler (0.17.0)
+# Autogenerated by Thrift Compiler (0.18.1)
 #
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
 #

server.thrift

@@ -3,6 +3,7 @@ namespace java io.e6x.engine.thrift
 exception QueryProcessingException
 {
     1: string reason,
+    2: string queryId,
 }
 
 exception AccessDeniedException

setup.py

@@ -16,7 +16,7 @@
 
 envstring = lambda var: os.environ.get(var) or ""
 
-VERSION = [1, 0, 3]
+VERSION = [1, 0, 4]
 
 
 def get_long_desc():

tests.py

@@ -3,7 +3,7 @@
 import time
 from unittest import TestCase
 import e6xdb.e6x as edb
-
+import json
 import logging
 
 logging.getLogger(__name__)
@@ -19,16 +19,9 @@ def setUp(self) -> None:
         self.e6x_connection = edb.connect(
             host=self._host,
             port=9000,
-            scheme='e6xdb',
             username='vishal@e6x.io',
             database=self._database,
-            auth=None,
-            configuration=None,
-            kerberos_service_name=None,
             password='75cei^%$TREdgfhU&T^RTYDrchfgvjy65dhcgf',
-            check_hostname=None,
-            ssl_cert=None,
-            thrift_transport=None
         )
         logging.debug('Successfully to connect to engine.')
 
@@ -97,13 +90,13 @@ def test_query_5_dry_run(self):
     def test_query_5_caches(self):
         sql = "select * from date_dim limit 3"
         logging.debug('Executing query: {}'.format(sql))
-        self.e6x_connection.set_or_update_caches(True)
+        self.e6x_connection.set_prop_map(json.dumps(dict(USE_QUERY_RESULT_CACHE=True)))
         cursor = self.e6x_connection.cursor()
         query_id = cursor.execute(sql)
         logging.debug('Query Id {}'.format(query_id))
         self.assertIsNotNone(query_id)
         records = cursor.fetchall()
-        self.e6x_connection.set_or_update_caches(False)
+        self.e6x_connection.set_prop_map(json.dumps(dict(USE_QUERY_RESULT_CACHE=False)))
         now = time.time()
         query_id = cursor.execute(sql)
         logging.debug('Query Id {}'.format(query_id))