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

Add the rename_media task

Browse Source
This commit is contained in:
tcely 2025-02-15 21:47:39 -05:00 committed by GitHub
parent ba612237f2
commit 041e088cdf
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
tubesync/sync/tasks.py
View File

@ -51,6 +51,7 @@ def map_task_to_instance(task):
'sync.tasks.download_media': Media,
'sync.tasks.download_media_metadata': Media,
'sync.tasks.save_all_media_for_source': Source,
'sync.tasks.rename_media': Media,
'sync.tasks.rename_all_media_for_source': Source,
'sync.tasks.wait_for_media_premiere': Media,
}
@ -574,7 +575,7 @@ def rescan_media_server(mediaserver_id):
mediaserver.update()
@background(schedule=0)
@background(schedule=0, remove_existing_tasks=True)
def save_all_media_for_source(source_id):
'''
Iterates all media items linked to a source and saves them to
@ -595,7 +596,16 @@ def save_all_media_for_source(source_id):
media.save()
@background(schedule=0)
@background(schedule=0, remove_existing_tasks=True)
def rename_media(media_id):
try:
media = Media.objects.get(pk=media_id)
except Media.DoesNotExist:
return
media.rename_files()
@background(schedule=0, remove_existing_tasks=True)
def rename_all_media_for_source(source_id):
try:
source = Source.objects.get(pk=source_id)
@ -607,7 +617,8 @@ def rename_all_media_for_source(source_id):
for media in Media.objects.filter(source=source):
media.rename_files()
@background(schedule=0)
@background(schedule=0, remove_existing_tasks=True)
def wait_for_media_premiere(media_id):
hours = lambda td: 1+int((24*td.days)+(td.seconds/(60*60)))