Method _precompute_for_push

sdk/python/feast/feature_store.py:2771–2796

Re-compute pre-computed vectors for entities affected by a push.

(self, feature_view_name: str, df: "pd.DataFrame")

                    )

    def _precompute_for_push(self, feature_view_name: str, df: "pd.DataFrame") -> None:
        """Re-compute pre-computed vectors for entities affected by a push."""
        try:
            services = self.registry.list_feature_services(self.project)
        except Exception:
            return

        affected = [
            svc
            for svc in services
            if svc.precompute_online
            and any(p.name == feature_view_name for p in svc.feature_view_projections)
        ]

        if not affected:
            return

        for svc in affected:
            try:
                self.precompute_feature_service(svc.name)
            except Exception:
                _logger.warning(
                    "Failed to precompute vectors for service '%s' after push",
                    svc.name,
                    exc_info=True,
                )

    def push(
        self,