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

Add migrate_queues function

Browse Source
This commit is contained in:
tcely 2025-04-07 03:51:33 -04:00 committed by GitHub
parent 379cafdec7
commit 0c056cc115
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tubesync/sync/tasks.py
View File

@ -192,6 +192,13 @@ def cleanup_completed_tasks():
CompletedTask.objects.filter(run_at__lt=delta).delete() CompletedTask.objects.filter(run_at__lt=delta).delete()
@atomic(durable=False)
def migrate_queues():
tqs = Task.objects.all()
qs = tqs.exclude(queue__in=TaskQueue.values)
return qs.update(queue=Val(TaskQueue.NET))
def schedule_media_servers_update(): def schedule_media_servers_update():
with atomic(): with atomic():
# Schedule a task to update media servers # Schedule a task to update media servers