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

Use repeat_until in the call

Browse Source
This commit is contained in:
tcely 2025-02-02 23:58:09 -05:00 committed by GitHub
parent a028b4ea26
commit b05d3854a1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
tubesync/sync/tasks.py
View File

@ -337,12 +337,13 @@ def download_media_metadata(media_id):
media.published = published_datetime
media.manual_skip = True
media.save()
verbose_name = _('Waiting for the premiere of "{}"')
verbose_name = _('Waiting for the premiere of "{}" at: {published_datetime}')
wait_for_media_premiere(
str(media.pk),
priority=0,
queue=str(media.pk),
repeat=Task.HOURLY,
repeat_until = published_datetime + timedelta(hours=2),
verbose_name=verbose_name.format(media.key),
)
log.exception(e)
@ -583,6 +584,8 @@ def wait_for_media_premiere(media_id):
media = Media.objects.get(pk=media_id)
except Media.DoesNotExist:
return
if media.metadata:
return
if media.published < timezone.now():
media.manual_skip = False
media.skip = False
@ -595,8 +598,6 @@ def wait_for_media_premiere(media_id):
if task:
task.verbose_name = _(f'Waiting for premiere of "{media.key}" '
f'in {hours(td(media.published))} hours')
if not task.repeat_until:
task.repeat_until = media.published + timedelta(hours=2)
task.save()
media.save()