From e8fd4bb0a9d3c2bc4f3f139f5ec82a2113ef8c71 Mon Sep 17 00:00:00 2001 From: Jonathan Date: Tue, 14 Jul 2026 23:40:33 +0200 Subject: [PATCH] feat(discover): supply Last.fm popularity to the sweep Co-Authored-By: Claude Opus 4.8 (1M context) --- worker/lyra_worker/main.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/worker/lyra_worker/main.py b/worker/lyra_worker/main.py index 0e5c1d8..165135c 100644 --- a/worker/lyra_worker/main.py +++ b/worker/lyra_worker/main.py @@ -15,7 +15,7 @@ from lyra_worker.library import clear_staging_root from lyra_worker.monitor import MonitorConfig, fulfill_owned_releases, reconcile, sweep from lyra_worker.pipeline import run_pipeline from lyra_worker.registry import ( - build_adapters, build_browser, build_probe, build_resolver, + build_adapters, build_album_popularity, build_browser, build_probe, build_resolver, build_similarity_sources, build_tagger, ) from lyra_worker.scan import build_worklist, clear_worklist, scan_chunk @@ -115,8 +115,10 @@ def maybe_run_scan(conn, resolver, probe, browser, config, dest_root: str = DEST def _run_discovery(conn, sources, browser, config=None) -> DiscoveryResult: - cfg = DiscoveryConfig.from_config(config if config is not None else get_config(conn)) - return run_discovery(conn, sources, browser, cfg) + resolved = config if config is not None else get_config(conn) + cfg = DiscoveryConfig.from_config(resolved) + popularity = build_album_popularity(resolved) + return run_discovery(conn, sources, browser, cfg, popularity=popularity) def finish_job(conn, job_id, mcfg) -> None: