pandora/pandora/tv/tasks.py

# -*- coding: utf-8 -*-
# vi:si:et:sw=4:sts=4:ts=4
from __future__ import division, print_function, absolute_import

from datetime import timedelta

from celery.task import periodic_task

from app.utils import limit_rate

from . import models


@periodic_task(run_every=timedelta(days=1), queue='encoding')
def update_program(**kwargs):
    if limit_rate('tv.tasks.update_program', 8 * 60 * 60):
        for c in models.Channel.objects.all():
            c.update_program()
update channels daily 2012-09-11 12:35:58 +00:00			`# -- coding: utf-8 --`
			`# vi:si:et:sw=4:sts=4:ts=4`
towards supporting python 2 and 3 - use absolute_imports - make use of six.moves - use exec instead of execfile - use list(dict) instead if dict.keys() 2016-08-23 10:27:06 +00:00			`from __future__ import division, print_function, absolute_import`

cleanup unused imports and unused variables 2013-02-21 13:28:36 +00:00			`from datetime import timedelta`
update channels daily 2012-09-11 12:35:58 +00:00
cleanup unused imports and unused variables 2013-02-21 13:28:36 +00:00			`from celery.task import periodic_task`
update channels daily 2012-09-11 12:35:58 +00:00
limit cronjob rate if multiple cronjobs end up in queue 2016-08-18 11:41:24 +00:00			`from app.utils import limit_rate`

towards supporting python 2 and 3 - use absolute_imports - make use of six.moves - use exec instead of execfile - use list(dict) instead if dict.keys() 2016-08-23 10:27:06 +00:00			`from . import models`
update channels daily 2012-09-11 12:35:58 +00:00
cleanup unused imports and unused variables 2013-02-21 13:28:36 +00:00
update channels daily 2012-09-11 12:35:58 +00:00			`@periodic_task(run_every=timedelta(days=1), queue='encoding')`
			`def update_program(**kwargs):`
limit cronjob rate if multiple cronjobs end up in queue 2016-08-18 11:41:24 +00:00			`if limit_rate('tv.tasks.update_program', 8 * 60 * 60):`
			`for c in models.Channel.objects.all():`
			`c.update_program()`