support downloading updated data

app.py

@@ -85,12 +85,11 @@ qs, qas = read_qs()
 start_time = time.time()
 num_read_qas = len(qas)
 
-def ask(query, max_attempt_times=3):
+def ask(query, timeout=600):
     answer = None
+    dead_time = time.time() + timeout
     attempt_times = 0
-    while answer is None and attempt_times<max_attempt_times:
-        wait_time = int(attempt_times*10)
-        time.sleep(wait_time)
+    while answer is None and time.time()<dead_time:
         try:
             answer = openai.ChatCompletion.create(
                 model="gpt-3.5-turbo",
@@ -99,18 +98,19 @@ def ask(query, max_attempt_times=3):
                 ]
             )["choices"][0]["message"]["content"]
         except Exception as e:
-            print(e)
-            if "You exceeded your current quota, please check your plan and billing details." in str(e):
-                idx = openai.api_keys.index(openai.api_key)
-                idx = (idx + 1) % len(openai.api_keys)
-                openai.api_key = openai.api_keys[idx]
-                attempt_times += 0
-                print(f"switch api_key")
-            elif "Request timed out: HTTPSConnectionPool(host='api.openai.com', port=443): Read timed out. (read timeout=600)" in str(e):
-                attempt_times += 1000
-            else:
-                attempt_times += 1
-                print(f"retry in {attempt_times*10} seconds...")
+            if time.time()<dead_time:
+                print(e)
+                if "You exceeded your current quota, please check your plan and billing details." in str(e):
+                    idx = openai.api_keys.index(openai.api_key)
+                    idx = (idx + 1) % len(openai.api_keys)
+                    openai.api_key = openai.api_keys[idx]
+                    attempt_times += 0
+                    print(f"switch api_key")
+                else:
+                    attempt_times += 1
+                    wait_time = int(attempt_times*10)
+                    time.sleep(wait_time)
+                    print(f"retry in {attempt_times*10} seconds...")
     return answer
 
 
@@ -122,7 +122,7 @@ def askingChatGPT(qs, qas, min_interval_seconds=3, max_interval_seconds=15, max_
         #a = ask(q)
         def ask_(q, timeout):
             executor = concurrent.futures.ThreadPoolExecutor()
-            future = executor.submit(ask, q)  # 提交函数调用任务
+            future = executor.submit(ask, q, timeout)  # 提交函数调用任务
             try:
                 a = future.result(timeout=timeout)  # 等待函数调用任务完成，超时时间为30秒
                 return a
@@ -170,9 +170,15 @@ def showcase(access_key):
 
 
 def download(access_key):
-    if not access_key==os.getenv('access_key'):
+    if not access_key.startswith(os.getenv('access_key')):
         chatbot_ret = [(f"Your entered Access Key:<br>{access_key}<br>is incorrect.", f"So i cannot provide you any information in this private space.")]
         file_ret = gr.File.update(value=None, visible=False)
+    elif: access_key == f"{os.getenv('access_key')}: update":
+        chatbot_ret = [(f"Your entered Access Key is correct.", f"The file containing new processed query-responses ({len(qas)-num_read_qas} in total) can be downloaded below.")]
+        filename = f"qas-{num_read_qas}-{len(qas)}.json"
+        with open(filename, "w", encoding="utf-8") as f:
+            f.write(json.dumps(qas[num_read_qas:], ensure_ascii=False, indent=2))
+        file_ret = gr.File.update(value=filename, visible=True)
     else:
         chatbot_ret = [(f"Your entered Access Key is correct.", f"The file containing all processed query-responses ({len(qas)} in total) can be downloaded below.")]
         filename = f"qas-{len(qas)}.json"

dialogues_set/qas.json

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:5d9eb4ab3d7f781cc43111beaebc295c888b625f02f61d6407a3f6e610c8f2a4
-size 24089657
+oid sha256:2edd0de80b0cad6a4af7ce82d7042ceed8305f490ae56cc70c5615225abdcb7d
+size 25058283