Add celery task to purge a list of datasets

galaxyproject · Feb 7, 2023 · da57f8a · da57f8a
1 parent 5ef066f
commit da57f8a
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/galaxy/celery/tasks.py b/lib/galaxy/celery/tasks.py
@@ -43,6 +43,7 @@
     ImportModelStoreTaskRequest,
     MaterializeDatasetInstanceTaskRequest,
     PrepareDatasetCollectionDownload,
+    PurgeDatasetsTaskRequest,
     SetupHistoryExportJob,
     WriteHistoryContentTo,
     WriteHistoryTo,
@@ -84,6 +85,11 @@ def purge_hda(hda_manager: HDAManager, hda_id: int):
     hda_manager._purge(hda)
 
 
+@galaxy_task(ignore_result=True, action="completely removes a set of datasets from the object_store")
+def purge_datasets(dataset_manager: DatasetManager, request: PurgeDatasetsTaskRequest):
+    dataset_manager.purge_datasets(request)
+
+
 @galaxy_task(ignore_result=True, action="materializing dataset instance")
 def materialize(
     hda_manager: HDAManager,