Spaces:
Sleeping
Sleeping
Rivalcoder
commited on
Commit
·
953f7ea
1
Parent(s):
cddddfc
[Edit] Update Url Parameter
Browse files- api/routes.py +8 -8
api/routes.py
CHANGED
@@ -13,7 +13,7 @@ from concurrent.futures import ThreadPoolExecutor
|
|
13 |
router = APIRouter()
|
14 |
|
15 |
class QueryRequest(BaseModel):
|
16 |
-
|
17 |
questions: list[str]
|
18 |
|
19 |
class LocalQueryRequest(BaseModel):
|
@@ -59,8 +59,8 @@ async def run_query(request: QueryRequest, fastapi_request: Request, background_
|
|
59 |
try:
|
60 |
user_ip = get_client_ip(fastapi_request)
|
61 |
user_agent = fastapi_request.headers.get("user-agent", "Unknown")
|
62 |
-
doc_id = get_document_id(request.
|
63 |
-
print("Input :",request.
|
64 |
# Parsing
|
65 |
t_parse_start = time.time()
|
66 |
with doc_cache_lock:
|
@@ -70,7 +70,7 @@ async def run_query(request: QueryRequest, fastapi_request: Request, background_
|
|
70 |
timings["parse_time"] = 0
|
71 |
timings["index_time"] = 0
|
72 |
else:
|
73 |
-
text_chunks = parse_document_url(request.
|
74 |
t_parse_end = time.time()
|
75 |
timings["parse_time"] = t_parse_end - t_parse_start
|
76 |
|
@@ -117,7 +117,7 @@ async def run_query(request: QueryRequest, fastapi_request: Request, background_
|
|
117 |
# Logging
|
118 |
total_float_time = sum(v for v in timings.values() if isinstance(v, (int, float)))
|
119 |
for q, a in zip(request.questions, responses):
|
120 |
-
background_tasks.add_task(log_query, request.
|
121 |
|
122 |
# Print timings in console
|
123 |
print_timings(timings)
|
@@ -201,7 +201,7 @@ async def run_query_openai(request: QueryRequest, fastapi_request: Request, back
|
|
201 |
try:
|
202 |
user_ip = get_client_ip(fastapi_request)
|
203 |
user_agent = fastapi_request.headers.get("user-agent", "Unknown")
|
204 |
-
doc_id = get_document_id(request.
|
205 |
|
206 |
# Parsing
|
207 |
t_parse_start = time.time()
|
@@ -212,7 +212,7 @@ async def run_query_openai(request: QueryRequest, fastapi_request: Request, back
|
|
212 |
timings["parse_time"] = 0
|
213 |
timings["index_time"] = 0
|
214 |
else:
|
215 |
-
text_chunks = parse_document_url(request.
|
216 |
t_parse_end = time.time()
|
217 |
timings["parse_time"] = t_parse_end - t_parse_start
|
218 |
|
@@ -259,7 +259,7 @@ async def run_query_openai(request: QueryRequest, fastapi_request: Request, back
|
|
259 |
# Logging
|
260 |
total_float_time = sum(v for v in timings.values() if isinstance(v, (int, float)))
|
261 |
for q, a in zip(request.questions, responses):
|
262 |
-
background_tasks.add_task(log_query, request.
|
263 |
|
264 |
# Print timings in console
|
265 |
print_timings(timings)
|
|
|
13 |
router = APIRouter()
|
14 |
|
15 |
class QueryRequest(BaseModel):
|
16 |
+
url: str
|
17 |
questions: list[str]
|
18 |
|
19 |
class LocalQueryRequest(BaseModel):
|
|
|
59 |
try:
|
60 |
user_ip = get_client_ip(fastapi_request)
|
61 |
user_agent = fastapi_request.headers.get("user-agent", "Unknown")
|
62 |
+
doc_id = get_document_id(request.url)
|
63 |
+
print("Input :",request.url,request.questions)
|
64 |
# Parsing
|
65 |
t_parse_start = time.time()
|
66 |
with doc_cache_lock:
|
|
|
70 |
timings["parse_time"] = 0
|
71 |
timings["index_time"] = 0
|
72 |
else:
|
73 |
+
text_chunks = parse_document_url(request.url)
|
74 |
t_parse_end = time.time()
|
75 |
timings["parse_time"] = t_parse_end - t_parse_start
|
76 |
|
|
|
117 |
# Logging
|
118 |
total_float_time = sum(v for v in timings.values() if isinstance(v, (int, float)))
|
119 |
for q, a in zip(request.questions, responses):
|
120 |
+
background_tasks.add_task(log_query, request.url, q, a, user_ip, total_float_time, user_agent)
|
121 |
|
122 |
# Print timings in console
|
123 |
print_timings(timings)
|
|
|
201 |
try:
|
202 |
user_ip = get_client_ip(fastapi_request)
|
203 |
user_agent = fastapi_request.headers.get("user-agent", "Unknown")
|
204 |
+
doc_id = get_document_id(request.url)
|
205 |
|
206 |
# Parsing
|
207 |
t_parse_start = time.time()
|
|
|
212 |
timings["parse_time"] = 0
|
213 |
timings["index_time"] = 0
|
214 |
else:
|
215 |
+
text_chunks = parse_document_url(request.url)
|
216 |
t_parse_end = time.time()
|
217 |
timings["parse_time"] = t_parse_end - t_parse_start
|
218 |
|
|
|
259 |
# Logging
|
260 |
total_float_time = sum(v for v in timings.values() if isinstance(v, (int, float)))
|
261 |
for q, a in zip(request.questions, responses):
|
262 |
+
background_tasks.add_task(log_query, request.url, q, a, user_ip, total_float_time, user_agent)
|
263 |
|
264 |
# Print timings in console
|
265 |
print_timings(timings)
|