Refactor: _run_scheduled_sync helper + background non-blocking trigger

app_v2_entry.py

@@ -1470,13 +1470,8 @@ def _scheduler_loop():
                 should_run = True
             if should_run and label not in today_log:
                 print(f"[auto] Detected missed slot {label} (h={h} < now={current_hour}:{current_minute}), running catch-up now")
-                loop = asyncio.new_event_loop()
-                asyncio.set_event_loop(loop)
-                try:
-                    loop.run_until_complete(_do_scheduled_run(label))
-                    _last_run_slots.add(label)
-                finally:
-                    loop.close()
+                _run_scheduled_sync(label)
+                _last_run_slots.add(label)
     except Exception as e:
         print(f"[auto] Catch-up check error: {e}")
     
@@ -1499,12 +1494,7 @@ def _scheduler_loop():
             
             if slot and slot not in _last_run_slots:
                 _last_run_slots.add(slot)
-                loop = asyncio.new_event_loop()
-                asyncio.set_event_loop(loop)
-                try:
-                    loop.run_until_complete(_do_scheduled_run(slot))
-                finally:
-                    loop.close()
+                _run_scheduled_sync(slot)
         except Exception as e:
             print(f"[auto] Loop error: {e}")
         
@@ -1531,14 +1521,21 @@ async def debug_auto_schedule(slot: str = '07:00'):
     except Exception as e:
         return JSONResponse({"error": str(e)}, status_code=500)
 
-@app.get('/api/debug/trigger_auto')
-async def debug_trigger_auto(slot: str = '19:00'):
-    """Trigger _do_scheduled_run and return result."""
+def _run_scheduled_sync(slot):
+    """Run _do_scheduled_run in a separate event loop (for background thread)."""
+    loop = asyncio.new_event_loop()
+    asyncio.set_event_loop(loop)
     try:
-        await _do_scheduled_run(slot)
-        return JSONResponse({"status": "ok", "slot": slot})
+        loop.run_until_complete(_do_scheduled_run(slot))
     except Exception as e:
-        import traceback
-        return JSONResponse({"error": str(e), "traceback": traceback.format_exc()}, status_code=500)
+        print(f"[auto] Background run error: {e}")
+    finally:
+        loop.close()
+
+@app.get('/api/debug/trigger_auto')
+async def debug_trigger_auto(slot: str = '19:00'):
+    """Trigger _do_scheduled_run in background thread (non-blocking)."""
+    threading.Thread(target=_run_scheduled_sync, args=(slot,), daemon=True).start()
+    return JSONResponse({"status": "started", "slot": slot})
 
 app.mount('/static',StaticFiles(directory=STATIC_DIR),name='vnews_static')