Update query.py

query.py

@@ -111,7 +111,7 @@ class VectaraQuery():
 
         endpoint = f"https://api.vectara.io/v1/query"
         body = self.get_body(query_str)
-        
+
         response = requests.post(endpoint, data=json.dumps(body), verify=True, headers=self.get_headers())    
         if response.status_code != 200:
             print(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
@@ -141,7 +141,9 @@ class VectaraQuery():
 
         endpoint = f"https://api.vectara.io/v1/stream-query"
         body = self.get_body(query_str)
-        
+
+        print(f"DEBUG body = {body}")        
+
         response = requests.post(endpoint, data=json.dumps(body), verify=True, headers=self.get_headers(), stream=True) 
         if response.status_code != 200:
             print(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
@@ -154,6 +156,8 @@ class VectaraQuery():
             if line:  # filter out keep-alive new lines
                 data = json.loads(line.decode('utf-8'))
                 res = data['result']
+                
+                print(f"DEBUG conv_id = {self.conv_id}, res = {res}")
 
                 # capture responses and docs if we get that first
                 response_set = res['responseSet']