Spaces:
Sleeping
Sleeping
Update query.py
Browse files
query.py
CHANGED
@@ -1,6 +1,10 @@
|
|
1 |
import requests
|
2 |
import json
|
3 |
|
|
|
|
|
|
|
|
|
4 |
|
5 |
class VectaraQuery():
|
6 |
def __init__(self, api_key: str, customer_id: str, corpus_ids: list[str], prompt_name: str = None):
|
@@ -68,6 +72,7 @@ class VectaraQuery():
|
|
68 |
|
69 |
response = requests.post(endpoint, data=json.dumps(body), verify=True, headers=self.get_headers())
|
70 |
if response.status_code != 200:
|
|
|
71 |
print(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
|
72 |
return "Sorry, something went wrong in my brain. Please try again later."
|
73 |
|
@@ -85,6 +90,7 @@ class VectaraQuery():
|
|
85 |
return 'Sorry, something went wrong in my brain. Please try again later.'
|
86 |
|
87 |
self.conv_id = chat['conversationId'] if chat else None
|
|
|
88 |
return summary
|
89 |
|
90 |
def submit_query_streaming(self, query_str: str):
|
@@ -94,6 +100,7 @@ class VectaraQuery():
|
|
94 |
|
95 |
response = requests.post(endpoint, data=json.dumps(body), verify=True, headers=self.get_headers(), stream=True)
|
96 |
if response.status_code != 200:
|
|
|
97 |
print(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
|
98 |
return "Sorry, something went wrong in my brain. Please try again later."
|
99 |
|
|
|
1 |
import requests
|
2 |
import json
|
3 |
|
4 |
+
import logging
|
5 |
+
|
6 |
+
logging.basicConfig(level=logging.DEBUG)
|
7 |
+
|
8 |
|
9 |
class VectaraQuery():
|
10 |
def __init__(self, api_key: str, customer_id: str, corpus_ids: list[str], prompt_name: str = None):
|
|
|
72 |
|
73 |
response = requests.post(endpoint, data=json.dumps(body), verify=True, headers=self.get_headers())
|
74 |
if response.status_code != 200:
|
75 |
+
logging.debug(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
|
76 |
print(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
|
77 |
return "Sorry, something went wrong in my brain. Please try again later."
|
78 |
|
|
|
90 |
return 'Sorry, something went wrong in my brain. Please try again later.'
|
91 |
|
92 |
self.conv_id = chat['conversationId'] if chat else None
|
93 |
+
logging.debug(summary)
|
94 |
return summary
|
95 |
|
96 |
def submit_query_streaming(self, query_str: str):
|
|
|
100 |
|
101 |
response = requests.post(endpoint, data=json.dumps(body), verify=True, headers=self.get_headers(), stream=True)
|
102 |
if response.status_code != 200:
|
103 |
+
logging.debug(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
|
104 |
print(f"Query failed with code {response.status_code}, reason {response.reason}, text {response.text}")
|
105 |
return "Sorry, something went wrong in my brain. Please try again later."
|
106 |
|