|
@@ -275,7 +275,7 @@ class ClusterPoller:
|
|
|
return []
|
|
return []
|
|
|
lookback = max_age if max_age > 0 else 72
|
|
lookback = max_age if max_age > 0 else 72
|
|
|
all_recent = self.store.get_latest_clusters_all_topics(ttl_hours=lookback, limit=500)
|
|
all_recent = self.store.get_latest_clusters_all_topics(ttl_hours=lookback, limit=500)
|
|
|
- recent = [c for c in all_recent if _cluster_is_within_age_window(c, max_age)]
|
|
|
|
|
|
|
+ recent = [c for c in all_recent if _cluster_is_within_age_window(c, max_age_hours=max_age)]
|
|
|
self.logger.info("pre-seeded: existing_clusters=%d max_age_h=%.1f", len(recent), max_age)
|
|
self.logger.info("pre-seeded: existing_clusters=%d max_age_h=%.1f", len(recent), max_age)
|
|
|
return recent
|
|
return recent
|
|
|
|
|
|