Function update_feature_freshness

sdk/python/feast/metrics.py:491–515

Compute and set the freshness gauge for every feature view in the registry. Freshness = now - most_recent_end_time (from materialization_intervals). A higher value means the feature data is more stale.

(
    store: "FeatureStore",
)

def update_feature_freshness(
    store: "FeatureStore",
) -> None:
    """
    Compute and set the freshness gauge for every feature view in the registry.

    Freshness = now - most_recent_end_time (from materialization_intervals).
    A higher value means the feature data is more stale.
    """
    try:
        feature_views = store.list_feature_views(allow_cache=True)
        stream_feature_views = store.list_stream_feature_views(allow_cache=True)
        all_views = feature_views + stream_feature_views
        now = datetime.now(tz=timezone.utc)
        for fv in all_views:
            end_time = fv.most_recent_end_time
            if end_time is not None:
                if end_time.tzinfo is None:
                    end_time = end_time.replace(tzinfo=timezone.utc)
                staleness = (now - end_time).total_seconds()
                feature_freshness_seconds.labels(
                    feature_view=fv.name, project=store.project
                ).set(staleness)
    except Exception:
        logger.debug("Failed to update feature freshness metrics", exc_info=True)


def monitor_resources(interval: int = 5):