Circuit-Forge/peregrine
2
0
Fork 0
Code Issues 22 Pull requests 2 Projects Releases 6 Packages Wiki Activity Actions

feat(app): use reset_running_tasks() on startup to preserve queued tasks

Browse source
This commit is contained in:
pyr0ball 2026-03-15 04:57:49 -07:00
parent 690a1ccf93
commit 6e0105b0e8
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
app/app.py
View file

@ -42,12 +42,12 @@ def _startup() -> None:
2. Auto-queues re-runs for any research generated without SearXNG data, 2. Auto-queues re-runs for any research generated without SearXNG data,
if SearXNG is now reachable. if SearXNG is now reachable.
""" """
# Reset only in-flight tasks — queued tasks survive for the scheduler to resume.
# MUST run before any submit_task() call in this function.
from scripts.db import reset_running_tasks
reset_running_tasks(get_db_path())
conn = sqlite3.connect(get_db_path()) conn = sqlite3.connect(get_db_path())
conn.execute(
"UPDATE background_tasks SET status='failed', error='Interrupted by server restart',"
" finished_at=datetime('now') WHERE status IN ('queued','running')"
)
conn.commit()
# Auto-recovery: re-run LLM-only research when SearXNG is available # Auto-recovery: re-run LLM-only research when SearXNG is available
try: try: