Update google_db.py

google_db.py

@@ -4,6 +4,7 @@ import os
 import asyncio
 import aiohttp
 
+from threading import Thread
 
 
 api_variabl = os.getenv('api_key')
@@ -18,7 +19,7 @@ async def async_save_db(data):
             else:
                 return False
 
-def save_db(app):
+def save_db():
     err = 0
 
     if api_variabl == request.args.get('api'):
@@ -39,12 +40,20 @@ def save_db(app):
 
         data = f"action=addData&dey={dey_db}&wek={wek_db}&v_hid={v_hid_db}&v_min={v_min_db}&ph={ph_db}&ec={ec_db}&tS={tS_db}&tA={tA_db}&hDm={hDm_db}&sVen={sVen_db}&ec_A_eep={ec_A_eep_db}&ec_B_eep={ec_B_eep_db}&ec_C_eep={ec_C_eep_db}"
 
-        # Отправляем корутину в существующий цикл событий
-        asyncio.run_coroutine_threadsafe(async_save_db(data), app.loop)
+        # Запускаем асинхронный запрос в отдельном потоке
+        loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(loop)
+        loop.run_until_complete(async_save_db(data))
+        loop.close()
 
     response_data = {
         "eep_set": globs.eep_set,
         "err": err
     }
 
-    return jsonify(response_data)
+    return jsonify(response_data)
+
+@app.route("/save_db", methods=['GET'])
+def handle_save_db():
+    response = save_db()
+    return response