(self, command: dict, key: str)
| 311 | assert "feature_service_name" in command |
| 312 | |
| 313 | def write_logged_features(self, command: dict, key: str): |
| 314 | self._validate_write_logged_features_parameters(command) |
| 315 | table = self.flights[key] |
| 316 | feature_service = self.store.get_feature_service( |
| 317 | command["feature_service_name"] |
| 318 | ) |
| 319 | |
| 320 | assert feature_service.logging_config is not None, ( |
| 321 | "feature service must have logging_config set" |
| 322 | ) |
| 323 | |
| 324 | assert_permissions( |
| 325 | resource=feature_service, |
| 326 | actions=[AuthzedAction.WRITE_OFFLINE], |
| 327 | ) |
| 328 | self.offline_store.write_logged_features( |
| 329 | config=self.store.config, |
| 330 | data=table, |
| 331 | source=FeatureServiceLoggingSource( |
| 332 | feature_service, self.store.config.project |
| 333 | ), |
| 334 | logging_config=feature_service.logging_config, |
| 335 | registry=self.store.registry, |
| 336 | ) |
| 337 | |
| 338 | def _validate_pull_all_from_table_or_query_parameters(self, command: dict): |
| 339 | assert "data_source_name" in command, ( |
no test coverage detected