Abdul-Ib commited on
Commit
8f5aa52
1 Parent(s): b80c41d

Update app.py

Browse files
Files changed (1) hide show
  1. app.py +8 -3
app.py CHANGED
@@ -4,6 +4,12 @@ from helper_functions import *
4
  from rank_bm25 import BM25L
5
  import time
6
  import pprint
 
 
 
 
 
 
7
 
8
  def predict(query):
9
  start_time = time.time()
@@ -15,7 +21,6 @@ def predict(query):
15
 
16
  # Base URL for the search API
17
  base_url = "https://api.omaline.dev/search/product/search"
18
- results = {}
19
 
20
  # Construct query string for API request
21
  query_string = "&".join([f"k={item}" for item in normalized_query_list])
@@ -98,7 +103,7 @@ def predict(query):
98
  semantic_scores = semantic_search(query, doc_embeddings)
99
  hybrid_scores = hybrid_search(keyword_scores, semantic_scores)
100
  is_cheapest(query, request_json)
101
- results[query] = rerank_results(request_json, hybrid_scores)
102
 
103
  process_end_time = time.time()
104
  process_time_taken = process_end_time - process_time
@@ -110,7 +115,7 @@ def predict(query):
110
  # "calculate_interrelations_time": calculate_interrelations_time,
111
  # "process_time": process_time_taken}
112
 
113
- return pprint.pformat(results, indent=4)
114
 
115
  except Exception as e:
116
  error_message = f"An error occurred during processing: {e}"
 
4
  from rank_bm25 import BM25L
5
  import time
6
  import pprint
7
+
8
+ def print_results(results):
9
+ result_string = ''
10
+ for hit in results:
11
+ result_string += pprint.pformat(hit, indent=4) + "\n"
12
+ return result_string.strip()
13
 
14
  def predict(query):
15
  start_time = time.time()
 
21
 
22
  # Base URL for the search API
23
  base_url = "https://api.omaline.dev/search/product/search"
 
24
 
25
  # Construct query string for API request
26
  query_string = "&".join([f"k={item}" for item in normalized_query_list])
 
103
  semantic_scores = semantic_search(query, doc_embeddings)
104
  hybrid_scores = hybrid_search(keyword_scores, semantic_scores)
105
  is_cheapest(query, request_json)
106
+ results = rerank_results(request_json, hybrid_scores)
107
 
108
  process_end_time = time.time()
109
  process_time_taken = process_end_time - process_time
 
115
  # "calculate_interrelations_time": calculate_interrelations_time,
116
  # "process_time": process_time_taken}
117
 
118
+ return print_results(results)
119
 
120
  except Exception as e:
121
  error_message = f"An error occurred during processing: {e}"