Jonathan/Lyra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: sweep orphaned staging dirs on worker startup

Browse Source
This commit is contained in:
Jonathan
2026-07-11 15:18:30 +02:00
parent 29604db9cd
commit fe973343ad
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker/lyra_worker/main.py
+3
View File
@@ -3,16 +3,19 @@ import time
from lyra_worker.claim import claim_next from lyra_worker.claim import claim_next
from lyra_worker.config import get_config from lyra_worker.config import get_config
from lyra_worker.db import wait_for_db from lyra_worker.db import wait_for_db
from lyra_worker.library import clear_staging_root
from lyra_worker.monitor import MonitorConfig, reconcile, sweep from lyra_worker.monitor import MonitorConfig, reconcile, sweep
from lyra_worker.pipeline import run_pipeline from lyra_worker.pipeline import run_pipeline
from lyra_worker.registry import build_adapters, build_browser, build_resolver, build_tagger from lyra_worker.registry import build_adapters, build_browser, build_resolver, build_tagger
IDLE_SLEEP = 2.0 IDLE_SLEEP = 2.0
MONITOR_TICK_SECONDS = 60.0 MONITOR_TICK_SECONDS = 60.0
DEST_ROOT = "/music" # must match run_pipeline's default library root
def run_forever() -> None: def run_forever() -> None:
conn = wait_for_db() conn = wait_for_db()
clear_staging_root(DEST_ROOT) # sweep any staging dirs orphaned by a prior crash
adapters = build_adapters(get_config(conn)) adapters = build_adapters(get_config(conn))
resolver = build_resolver() resolver = build_resolver()
tagger = build_tagger() tagger = build_tagger()