mygpo/directory/tasks.py

   1 from mygpo.podcasts.models import Podcast
   2 from mygpo.cel import celery
   3 from mygpo.db.couchdb.podcast_state import podcast_subscriber_count
   4
   5
   6 @celery.task(max_retries=5)
   7 def update_podcast_subscribers(podcast_id):
   8     """ Updates the subscriber count of a podcast """
   9
  10     try:
  11         podcast = Podcast.objects.get(id=podcast_id)
  12
  13         # calculate current number of subscribers
  14         subscriber_count = podcast_subscriber_count(podcast)
  15         podcast.subscribers = subscriber_count
  16         podcast.save()
  17
  18     #TODO: which exceptions?
  19     except Exception as ex:
  20         raise update_podcast_subscribers.retry(exc=ex)