(
self, request: RegistryServer_pb2.ApplyMaterializationRequest, context
)
| 973 | ) |
| 974 | |
| 975 | def ApplyMaterialization( |
| 976 | self, request: RegistryServer_pb2.ApplyMaterializationRequest, context |
| 977 | ): |
| 978 | assert_permissions( |
| 979 | resource=FeatureView.from_proto(request.feature_view), |
| 980 | actions=[AuthzedAction.WRITE_ONLINE], |
| 981 | ) |
| 982 | |
| 983 | self.proxied_registry.apply_materialization( |
| 984 | feature_view=FeatureView.from_proto(request.feature_view), |
| 985 | project=request.project, |
| 986 | start_date=datetime.fromtimestamp( |
| 987 | request.start_date.seconds + request.start_date.nanos / 1e9, |
| 988 | tz=timezone.utc, |
| 989 | ), |
| 990 | end_date=datetime.fromtimestamp( |
| 991 | request.end_date.seconds + request.end_date.nanos / 1e9, tz=timezone.utc |
| 992 | ), |
| 993 | commit=request.commit, |
| 994 | ) |
| 995 | return Empty() |
| 996 | |
| 997 | def UpdateInfra(self, request: RegistryServer_pb2.UpdateInfraRequest, context): |
| 998 | project = self.proxied_registry.get_project( |
nothing calls this directly
no test coverage detected