feat: wire MusicBrainz resolver into the worker loop

This commit is contained in:
Jonathan
2026-07-10 23:27:28 +02:00
parent 85c74ba109
commit fef8cf0681
3 changed files with 39 additions and 2 deletions
+3 -2
View File
@@ -4,7 +4,7 @@ from lyra_worker.claim import claim_next
from lyra_worker.config import get_config
from lyra_worker.db import wait_for_db
from lyra_worker.pipeline import run_pipeline
from lyra_worker.registry import build_adapters
from lyra_worker.registry import build_adapters, build_resolver
IDLE_SLEEP = 2.0
@@ -12,6 +12,7 @@ IDLE_SLEEP = 2.0
def run_forever() -> None:
conn = wait_for_db()
adapters = build_adapters(get_config(conn))
resolver = build_resolver()
print(f"worker: {len(adapters)} adapter(s) enabled: {[a.name for a in adapters]}", flush=True)
print("worker: waiting for jobs", flush=True)
try:
@@ -21,7 +22,7 @@ def run_forever() -> None:
time.sleep(IDLE_SLEEP)
continue
print(f"worker: claimed job {job_id}", flush=True)
run_pipeline(conn, job_id, adapters)
run_pipeline(conn, job_id, adapters, resolver=resolver)
print(f"worker: finished job {job_id}", flush=True)
finally:
conn.close()