From 5db94c08d1fe124e8f40828ae5a86304fa2d5853 Mon Sep 17 00:00:00 2001 From: tcely Date: Sun, 15 Jun 2025 16:13:49 -0400 Subject: [PATCH] fixup: revoke the task objects --- tubesync/common/huey.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tubesync/common/huey.py b/tubesync/common/huey.py index f33d946d..1624d793 100644 --- a/tubesync/common/huey.py +++ b/tubesync/common/huey.py @@ -30,7 +30,7 @@ def h_q_reset_tasks(q, /, *, maint_func=None): from django_huey import get_queue q = get_queue(q) # revoke to prevent pending tasks from executing - for t in q._registry._registry: + for t in q._registry._registry.values(): q.revoke_all(t, revoke_until=delay_to_eta(600)) # clear scheduled tasks q.storage.flush_schedule()