forked from 0x2620/pandora
only update item timeline once all parts are done
This commit is contained in:
parent
f6cebcaec9
commit
697e501a4f
1 changed files with 3 additions and 3 deletions
|
@ -1,12 +1,11 @@
|
||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
# vi:si:et:sw=4:sts=4:ts=4
|
# vi:si:et:sw=4:sts=4:ts=4
|
||||||
import os
|
|
||||||
from glob import glob
|
from glob import glob
|
||||||
|
|
||||||
from celery.task import task
|
from celery.task import task
|
||||||
|
|
||||||
from django.conf import settings
|
from django.conf import settings
|
||||||
import ox
|
from django.db.models import Q
|
||||||
|
|
||||||
from item.models import Item
|
from item.models import Item
|
||||||
import models
|
import models
|
||||||
|
@ -107,7 +106,8 @@ def process_stream(fileId):
|
||||||
file.encoding = False
|
file.encoding = False
|
||||||
file.save()
|
file.save()
|
||||||
file.item.update_selected(update_timeline=False)
|
file.item.update_selected(update_timeline=False)
|
||||||
if not file.item.rendered:
|
if not file.item.rendered \
|
||||||
|
and not file.item.files.exclude(id=fileId).filter(Q(queued=True)|Q(encoding=True)).count():
|
||||||
file.item.update_timeline()
|
file.item.update_timeline()
|
||||||
if file.item.rendered:
|
if file.item.rendered:
|
||||||
file.item.save()
|
file.item.save()
|
||||||
|
|
Loading…
Reference in a new issue