forked from 0x2620/pandora
processing
This commit is contained in:
parent
c74efdd2ce
commit
205304a66f
1 changed files with 3 additions and 2 deletions
|
@ -91,10 +91,11 @@ def update_files(user, volume, files):
|
||||||
|
|
||||||
@task(queue="encoding")
|
@task(queue="encoding")
|
||||||
def process_stream(fileId):
|
def process_stream(fileId):
|
||||||
file = models.Stream.objects.get(id=fileId)
|
file = models.File.objects.get(id=fileId)
|
||||||
streams = file.streams.filter(source=None)
|
streams = file.streams.filter(source=None)
|
||||||
if streams.count() > 0:
|
if streams.count() > 0:
|
||||||
stream = streams[0]
|
stream = streams[0]
|
||||||
stream.make_timeline()
|
stream.make_timeline()
|
||||||
stream.extract_derivatives()
|
stream.extract_derivatives()
|
||||||
|
file.item.update_timeline()
|
||||||
return True
|
return True
|
||||||
|
|
Loading…
Reference in a new issue