Method ApplyFeatureView

sdk/python/feast/registry_server.py:349–414

(
        self, request: RegistryServer_pb2.ApplyFeatureViewRequest, context
    )

        )

    def ApplyFeatureView(
        self, request: RegistryServer_pb2.ApplyFeatureViewRequest, context
    ):
        from feast.labeling.label_view import LabelView

        feature_view_type = request.WhichOneof("base_feature_view")
        feature_view_meta: BaseFeatureView

        if feature_view_type == "feature_view":
            feature_view_meta = FeatureView.from_proto(
                request.feature_view, skip_udf=True
            )
        elif feature_view_type == "on_demand_feature_view":
            feature_view_meta = OnDemandFeatureView.from_proto(
                request.on_demand_feature_view, skip_udf=True
            )
        elif feature_view_type == "stream_feature_view":
            feature_view_meta = StreamFeatureView.from_proto(
                request.stream_feature_view, skip_udf=True
            )
        elif feature_view_type == "label_view":
            feature_view_meta = LabelView.from_proto(request.label_view)
        else:
            raise ValueError(f"Unexpected feature view type: {feature_view_type}")

        getter: Callable
        if isinstance(feature_view_meta, StreamFeatureView):
            getter = self.proxied_registry.get_stream_feature_view
        elif isinstance(feature_view_meta, FeatureView):
            getter = self.proxied_registry.get_feature_view
        elif isinstance(feature_view_meta, OnDemandFeatureView):
            getter = self.proxied_registry.get_on_demand_feature_view
        elif isinstance(feature_view_meta, LabelView):
            getter = self.proxied_registry.get_label_view
        else:
            getter = self.proxied_registry.get_feature_view

        assert_permissions_to_update(
            resource=cast(FeastObject, feature_view_meta),
            getter=cast(Callable, getter),
            project=request.project,
        )

        feature_view: BaseFeatureView
        if feature_view_type == "feature_view":
            feature_view = FeatureView.from_proto(request.feature_view)
        elif feature_view_type == "on_demand_feature_view":
            feature_view = OnDemandFeatureView.from_proto(
                request.on_demand_feature_view
            )
        elif feature_view_type == "stream_feature_view":
            feature_view = StreamFeatureView.from_proto(request.stream_feature_view)
        elif feature_view_type == "label_view":
            feature_view = LabelView.from_proto(request.label_view)
        else:
            raise ValueError(f"Unexpected feature view type: {feature_view_type}")

        (