exp: use queue remove in gc

This commit is contained in:
Peter Rowlands
2022-07-12 21:39:49 +09:00
committed by Peter Rowlands (변기호)
parent 33dbdd20af
commit c16908e9fc
+5 -4
View File
@@ -42,11 +42,12 @@ def gc(
removed = len(to_remove)
delete_stashes = []
for _, entry in repo.experiments.workspace_queue.stash.stash_revs.items():
stash = repo.experiments.celery_queue.stash
for stash_rev, entry in stash.stash_revs.items():
if not queued or entry.baseline_rev not in keep_revs:
delete_stashes.append(entry.stash_index)
for index in sorted(delete_stashes, reverse=True):
repo.experiments.workspace_queue.stash.drop(index)
delete_stashes.append(stash_rev)
if delete_stashes:
repo.experiments.celery_queue.remove(delete_stashes)
removed += len(delete_stashes)
return removed