(self, name: str, project: str, commit: bool = True)
| 430 | self.commit() |
| 431 | |
| 432 | def delete_data_source(self, name: str, project: str, commit: bool = True): |
| 433 | self._prepare_registry_for_changes(project) |
| 434 | assert self.cached_registry_proto |
| 435 | |
| 436 | for idx, data_source_proto in enumerate( |
| 437 | self.cached_registry_proto.data_sources |
| 438 | ): |
| 439 | if data_source_proto.name == name and data_source_proto.project == project: |
| 440 | del self.cached_registry_proto.data_sources[idx] |
| 441 | if commit: |
| 442 | self.commit() |
| 443 | return |
| 444 | raise DataSourceNotFoundException(name) |
| 445 | |
| 446 | def apply_feature_service( |
| 447 | self, feature_service: FeatureService, project: str, commit: bool = True |
no test coverage detected