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

    def run(self, feed_pk, **kwargs):
        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`

Defining the run task for celery's refresh feeds. 2010-08-31 18:18:40 -04:00			`def run(self, feed_pk, **kwargs):`
Adding celery tasks, config, and djcelery app. 2010-08-31 18:07:47 -04:00			`feed = Feed.objects.get(pk=feed_pk)`
			`feed.update()`