diff --git a/muninn/consolidation/daemon.py b/muninn/consolidation/daemon.py index 22ddbe5..ab6a076 100644 --- a/muninn/consolidation/daemon.py +++ b/muninn/consolidation/daemon.py @@ -204,22 +204,18 @@ async def _phase_decay(self) -> dict: record_ids, lookback_days=30, estimator="snips" ) - for record in records: - # Get centrality from pre-fetched map - centrality = centrality_map.get(record.id, 0.0) - - # Get max similarity for novelty calculation - max_sim = 0.0 # Would need vector lookup — simplified for now + c_get = centrality_map.get + u_get = utility_map.get - # SNIPS retrieval utility from pre-fetched batch map - ret_util = utility_map.get(record.id, 0.0) + for record in records: + rid = record.id # Recalculate importance new_importance = calculate_importance( record, - max_similarity=max_sim, - centrality=centrality, - retrieval_utility=ret_util, + max_similarity=0.0, # Would need vector lookup — simplified for now + centrality=c_get(rid, 0.0), + retrieval_utility=u_get(rid, 0.0), ) if new_importance != record.importance: