cablegates/pandora/item/tasks.py
j 7ca86a952e - register based api registration
- move review whitelist into config
2010-12-22 13:15:37 +05:30

38 lines
994 B
Python

# -*- coding: utf-8 -*-
# vi:si:et:sw=4:sts=4:ts=4
from datetime import timedelta
from celery.decorators import task, periodic_task
import load
import models
@periodic_task(run_every=timedelta(days=1))
def cronjob(**kwargs):
print "do some cleanup stuff once a day"
@task(ignore_resulsts=True, queue='default')
def update_poster(itemId):
item = models.Item.objects.get(itemId=itemId)
item.make_poster(True)
@task(ignore_resulsts=True, queue='default')
def update_imdb(imdbId):
item = models.Item.objects.get(itemId=imdbId)
item.update_imdb()
@task(ignore_resulsts=True)
def find_item(fileId):
f = models.File.objects.get(pk=fileId)
f.find_item()
@task(queue="encoding")
def update_streams(itemId):
'''
create stream, extract timeline and create derivatives
'''
item = models.Item.objects.get(itemId=itemId)
if item.files.filter(is_main=True, is_video=True, available=False).count() == 0:
item.update_streams()
return True