Reads logged features for the specified time window. Args: feature_service: The feature service whose logs should be retrieved. start_date: The start of the window. end_date: The end of the window. config: The config for the current f
(
self,
feature_service: FeatureService,
start_date: datetime,
end_date: datetime,
config: RepoConfig,
registry: BaseRegistry,
)
| 400 | |
| 401 | @abstractmethod |
| 402 | def retrieve_feature_service_logs( |
| 403 | self, |
| 404 | feature_service: FeatureService, |
| 405 | start_date: datetime, |
| 406 | end_date: datetime, |
| 407 | config: RepoConfig, |
| 408 | registry: BaseRegistry, |
| 409 | ) -> RetrievalJob: |
| 410 | """ |
| 411 | Reads logged features for the specified time window. |
| 412 | |
| 413 | Args: |
| 414 | feature_service: The feature service whose logs should be retrieved. |
| 415 | start_date: The start of the window. |
| 416 | end_date: The end of the window. |
| 417 | config: The config for the current feature store. |
| 418 | registry: The registry for the current feature store. |
| 419 | |
| 420 | Returns: |
| 421 | A RetrievalJob that can be executed to get the feature service logs. |
| 422 | """ |
| 423 | pass |
| 424 | |
| 425 | def get_feature_server_endpoint(self) -> Optional[str]: |
| 426 | """Returns endpoint for the feature server, if it exists.""" |
no outgoing calls
no test coverage detected