update task after updating item

This commit is contained in:
j 2016-08-25 18:30:52 +02:00
parent 1dd574cb9e
commit 11e36b550e

View file

@ -135,8 +135,8 @@ def process_stream(fileId):
file.item.update_timeline() file.item.update_timeline()
if file.item.rendered: if file.item.rendered:
file.item.save() file.item.save()
Task.finish(file.item)
models.File.objects.filter(id=fileId).update(encoding=False) models.File.objects.filter(id=fileId).update(encoding=False)
Task.finish(file.item)
return True return True
@task(queue="encoding") @task(queue="encoding")
@ -164,8 +164,8 @@ def extract_stream(fileId):
file.item.update_timeline() file.item.update_timeline()
update_poster(file.item.public_id) update_poster(file.item.public_id)
file.extract_tracks() file.extract_tracks()
Task.finish(file.item)
models.File.objects.filter(id=fileId).update(encoding=False) models.File.objects.filter(id=fileId).update(encoding=False)
Task.finish(file.item)
@task(queue="encoding") @task(queue="encoding")
def extract_derivatives(fileId, rebuild=False): def extract_derivatives(fileId, rebuild=False):