0x2620/pandora
2
1
Fork 1
Code Issues 1.3k Pull requests Releases Wiki Activity

finish tasks without error if item no longer exists

Browse source
This commit is contained in:
j 2016-11-28 15:10:46 +01:00
parent dc9bcd396d
commit 14bfb1a451
1 changed files with 24 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
pandora/item/tasks.py
View file

@ -54,13 +54,19 @@ def update_random_clip_sort():
@task(ignore_results=True, queue='default') @task(ignore_results=True, queue='default')
def update_clips(public_id): def update_clips(public_id):
from . import models from . import models
item = models.Item.objects.get(public_id=public_id) try:
item = models.Item.objects.get(public_id=public_id)
except models.Item.DoesNotExist:
return
item.clips.all().update(user=item.user.id) item.clips.all().update(user=item.user.id)
@task(ignore_results=True, queue='default') @task(ignore_results=True, queue='default')
def update_poster(public_id): def update_poster(public_id):
from . import models from . import models
item = models.Item.objects.get(public_id=public_id) try:
item = models.Item.objects.get(public_id=public_id)
except models.Item.DoesNotExist:
return
item.remove_poster() item.remove_poster()
item.make_poster() item.make_poster()
item.make_icon() item.make_icon()
@ -75,19 +81,28 @@ def update_poster(public_id):
@task(ignore_results=True, queue='default') @task(ignore_results=True, queue='default')
def update_file_paths(public_id): def update_file_paths(public_id):
from . import models from . import models
item = models.Item.objects.get(public_id=public_id) try:
item = models.Item.objects.get(public_id=public_id)
except models.Item.DoesNotExist:
return
item.update_file_paths() item.update_file_paths()
@task(ignore_results=True, queue='default') @task(ignore_results=True, queue='default')
def update_external(public_id): def update_external(public_id):
from . import models from . import models
item = models.Item.objects.get(public_id=public_id) try:
item = models.Item.objects.get(public_id=public_id)
except models.Item.DoesNotExist:
return
item.update_external() item.update_external()
@task(queue="encoding") @task(queue="encoding")
def update_timeline(public_id): def update_timeline(public_id):
from . import models from . import models
item = models.Item.objects.get(public_id=public_id) try:
item = models.Item.objects.get(public_id=public_id)
except models.Item.DoesNotExist:
return
item.update_timeline(async=False) item.update_timeline(async=False)
Task.finish(item) Task.finish(item)
@ -102,7 +117,10 @@ def rebuild_timeline(public_id):
@task(queue="encoding") @task(queue="encoding")
def load_subtitles(public_id): def load_subtitles(public_id):
from . import models from . import models
item = models.Item.objects.get(public_id=public_id) try:
item = models.Item.objects.get(public_id=public_id)
except models.Item.DoesNotExist:
return
if item.load_subtitles(): if item.load_subtitles():
item.update_find() item.update_find()
item.update_sort() item.update_sort()