(
self, request: RegistryServer_pb2.ListStreamFeatureViewsRequest, context
)
| 610 | ).to_proto() |
| 611 | |
| 612 | def ListStreamFeatureViews( |
| 613 | self, request: RegistryServer_pb2.ListStreamFeatureViewsRequest, context |
| 614 | ): |
| 615 | paginated_stream_feature_views, pagination_metadata = ( |
| 616 | apply_pagination_and_sorting( |
| 617 | permitted_resources( |
| 618 | resources=cast( |
| 619 | list[FeastObject], |
| 620 | self.proxied_registry.list_stream_feature_views( |
| 621 | project=request.project, |
| 622 | allow_cache=request.allow_cache, |
| 623 | tags=dict(request.tags), |
| 624 | skip_udf=True, |
| 625 | ), |
| 626 | ), |
| 627 | actions=AuthzedAction.DESCRIBE, |
| 628 | ), |
| 629 | pagination=request.pagination, |
| 630 | sorting=request.sorting, |
| 631 | ) |
| 632 | ) |
| 633 | |
| 634 | return RegistryServer_pb2.ListStreamFeatureViewsResponse( |
| 635 | stream_feature_views=[ |
| 636 | stream_feature_view.to_proto() |
| 637 | for stream_feature_view in paginated_stream_feature_views |
| 638 | ], |
| 639 | pagination=pagination_metadata, |
| 640 | ) |
| 641 | |
| 642 | def GetOnDemandFeatureView( |
| 643 | self, request: RegistryServer_pb2.GetOnDemandFeatureViewRequest, context |
nothing calls this directly
no test coverage detected