hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-23 21:46:44 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

fixup: revoke the task objects

Browse Source
This commit is contained in:
tcely 2025-06-15 16:13:49 -04:00 committed by GitHub
parent 9dc1376acc
commit 5db94c08d1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tubesync/common/huey.py
View File

@ -30,7 +30,7 @@ def h_q_reset_tasks(q, /, *, maint_func=None):
from django_huey import get_queue from django_huey import get_queue
q = get_queue(q) q = get_queue(q)
# revoke to prevent pending tasks from executing # 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)) q.revoke_all(t, revoke_until=delay_to_eta(600))
# clear scheduled tasks # clear scheduled tasks
q.storage.flush_schedule() q.storage.flush_schedule()