(
self, data_source: DataSource, project: str, commit: bool = True
)
| 193 | return [Entity.from_proto(entity) for entity in response.entities] |
| 194 | |
| 195 | def apply_data_source( |
| 196 | self, data_source: DataSource, project: str, commit: bool = True |
| 197 | ): |
| 198 | request = RegistryServer_pb2.ApplyDataSourceRequest( |
| 199 | data_source=data_source.to_proto(), project=project, commit=commit |
| 200 | ) |
| 201 | self.stub.ApplyDataSource(request) |
| 202 | |
| 203 | def delete_data_source(self, name: str, project: str, commit: bool = True): |
| 204 | request = RegistryServer_pb2.DeleteDataSourceRequest( |
nothing calls this directly
no test coverage detected