add unregister logic

This commit is contained in:
Vladislav 2024-12-05 17:17:44 +01:00
parent 02528986e6
commit d85a322f3b

View file

@ -125,6 +125,8 @@ class LocalFSDatasetIOImpl(DatasetIO, DatasetsProtocolPrivate):
)
async def unregister_dataset(self, dataset_id: str) -> None:
key = f"{DATASETS_PREFIX}{dataset_id}"
await self.kvstore.delete(key=key)
del self.dataset_infos[dataset_id]
async def get_rows_paginated(