2010-08-31 18:07:47 -04:00
|
|
|
from celery.task import Task
|
|
|
|
|
from apps.rss_feeds.models import Feed
|
2010-11-07 00:40:26 -04:00
|
|
|
# from utils import log as logging
|
2010-08-31 18:07:47 -04:00
|
|
|
|
2010-09-20 19:22:19 -04:00
|
|
|
class UpdateFeeds(Task):
|
|
|
|
|
name = 'update-feeds'
|
2010-08-31 18:07:47 -04:00
|
|
|
max_retries = 0
|
2010-09-01 08:19:58 -04:00
|
|
|
ignore_result = True
|
2010-08-31 18:07:47 -04:00
|
|
|
|
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)
|
2010-11-07 00:40:26 -04:00
|
|
|
# logging.debug(' Updating: [%s] %s' % (feed_pks, feed))
|
2010-09-01 10:37:58 -04:00
|
|
|
feed.update()
|
2010-08-31 18:07:47 -04:00
|
|
|
|
2010-09-28 05:16:00 -04:00
|
|
|
class NewFeeds(Task):
|
2010-09-20 19:22:19 -04:00
|
|
|
name = 'new-feeds'
|
2010-09-28 05:16:00 -04:00
|
|
|
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()
|
