Background thread target that periodically updates feature freshness gauges.
(store: "FeatureStore", interval: int = 30)
| 531 | |
| 532 | |
| 533 | def monitor_freshness(store: "FeatureStore", interval: int = 30): |
| 534 | """Background thread target that periodically updates feature freshness gauges.""" |
| 535 | logger.debug( |
| 536 | "Starting feature freshness monitoring with interval %d seconds", interval |
| 537 | ) |
| 538 | while True: |
| 539 | update_feature_freshness(store) |
| 540 | time.sleep(interval) |
| 541 | |
| 542 | |
| 543 | # --------------------------------------------------------------------------- |
nothing calls this directly
no test coverage detected