Cleanup cancelled tasks as well (#20068)

Rather than just completed and failed tasks.
This commit is contained in:
Erik Johnston
2026-08-06 18:11:32 +01:00
committed by GitHub
parent c5f02a9313
commit e3d9b15cc6
2 changed files with 3 additions and 2 deletions
+1
View File
@@ -0,0 +1 @@
Routinely purge old cancelled tasks from the database.
+2 -2
View File
@@ -400,10 +400,10 @@ class TaskScheduler:
"""Clean old complete or failed jobs to avoid clutter the DB."""
now = self._clock.time_msec()
for task in await self._store.get_scheduled_tasks(
statuses=[TaskStatus.FAILED, TaskStatus.COMPLETE],
statuses=[TaskStatus.FAILED, TaskStatus.CANCELLED, TaskStatus.COMPLETE],
max_timestamp=now - TaskScheduler.KEEP_TASKS_FOR_MS,
):
# FAILED and COMPLETE tasks should never be running
# FAILED, CANCELLED and COMPLETE tasks should never be running
assert task.id not in self._running_tasks
await self._store.delete_scheduled_task(task.id)