NewsBlur/apps/rss_feeds/tasks.py

from celery.task import Task
from apps.rss_feeds.models import Feed

class RefreshFeed(Task):
    name = 'refresh-feed'
    max_retries = 0
    ignore_result = True

    def run(self, feed_pks, **kwargs):
        if not isinstance(feed_pks, list):
            feed_pks = [feed_pks]
            
        for feed_pk in feed_pks:
            feed = Feed.objects.get(pk=feed_pk)
            feed.update()
Adding celery tasks, config, and djcelery app. 2010-08-31 18:07:47 -04:00			`from celery.task import Task`
			`from apps.rss_feeds.models import Feed`

			`class RefreshFeed(Task):`
			`name = 'refresh-feed'`
			`max_retries = 0`
Celery options for performance. 2010-09-01 08:19:58 -04:00			`ignore_result = True`
Adding celery tasks, config, and djcelery app. 2010-08-31 18:07:47 -04:00
Using a list of feed_pks instead of one. Less task overhead. 2010-09-01 10:37:58 -04:00			`def run(self, feed_pks, **kwargs):`
			`if not isinstance(feed_pks, list):`
			`feed_pks = [feed_pks]`

			`for feed_pk in feed_pks:`
			`feed = Feed.objects.get(pk=feed_pk)`
			`feed.update()`
Adding celery tasks, config, and djcelery app. 2010-08-31 18:07:47 -04:00