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

feat(discover): supply Last.fm popularity to the sweep

Browse Source 
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
This commit is contained in:
Jonathan
2026-07-14 23:40:33 +02:00
parent 194b4911c7
commit e8fd4bb0a9
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
worker/lyra_worker/main.py
+5 -3
View File
@@ -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.monitor import MonitorConfig, fulfill_owned_releases, reconcile, sweep
from lyra_worker.pipeline import run_pipeline from lyra_worker.pipeline import run_pipeline
from lyra_worker.registry import ( 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, build_similarity_sources, build_tagger,
) )
from lyra_worker.scan import build_worklist, clear_worklist, scan_chunk 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: def _run_discovery(conn, sources, browser, config=None) -> DiscoveryResult:
cfg = DiscoveryConfig.from_config(config if config is not None else get_config(conn)) resolved = config if config is not None else get_config(conn)
return run_discovery(conn, sources, browser, cfg) 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: def finish_job(conn, job_id, mcfg) -> None: