Update app.py

app.py

@@ -107,48 +107,45 @@ def load_keys():
     然后记录到日志中。
     使用线程池并发处理每个 key。
     """
-    if keys_str:
-        keys = [key.strip() for key in keys_str.split(',')]
-        unique_keys = list(set(keys))
-        keys_str = ','.join(unique_keys) 
-        os.environ["KEYS"] = keys_str
-
-        logging.info(f"加载的 keys：{unique_keys}")
-
-        with concurrent.futures.ThreadPoolExecutor(
-            max_workers=1000
-        ) as executor:
-            future_to_key = {
-                executor.submit(
-                    process_key, key, test_model
-                ): key for key in unique_keys
-            }
 
-            invalid_keys = []
-            valid_keys = []
-
-            for future in concurrent.futures.as_completed(
-                future_to_key
-            ):
-                key = future_to_key[future]
-                try:
-                    key_type = future.result()
-                    if key_type == "invalid":
-                        invalid_keys.append(key)
-                    elif key_type == "valid":
-                        valid_keys.append(key)
-                except Exception as exc:
-                    logging.error(f"处理 KEY {key} 生成异常: {exc}")
-
-        logging.info(f"无效 KEY：{invalid_keys}")
-        logging.info(f"有效 KEY：{valid_keys}")
-
-        global invalid_keys_global, valid_keys_global
-        invalid_keys_global = invalid_keys
-        valid_keys_global = valid_keys
+    keys = [key.strip() for key in keys_str.split(',')]
+    unique_keys = list(set(keys))
+    keys_str = ','.join(unique_keys) 
+    os.environ["KEYS"] = keys_str
 
-    else:
-        logging.warning("环境变量 KEYS 未设置。")
+    logging.info(f"加载的 keys：{unique_keys}")
+
+    with concurrent.futures.ThreadPoolExecutor(
+        max_workers=1000
+    ) as executor:
+        future_to_key = {
+            executor.submit(
+                process_key, key, test_model
+            ): key for key in unique_keys
+        }
+
+        invalid_keys = []
+        valid_keys = []
+
+        for future in concurrent.futures.as_completed(
+            future_to_key
+        ):
+            key = future_to_key[future]
+            try:
+                key_type = future.result()
+                if key_type == "invalid":
+                    invalid_keys.append(key)
+                elif key_type == "valid":
+                    valid_keys.append(key)
+            except Exception as exc:
+                logging.error(f"处理 KEY {key} 生成异常: {exc}")
+
+    logging.info(f"无效 KEY：{invalid_keys}")
+    logging.info(f"有效 KEY：{valid_keys}")
+
+    global invalid_keys_global, valid_keys_global
+    invalid_keys_global = invalid_keys
+    valid_keys_global = valid_keys
 
 def process_key(key, test_model):
     """