mygpo/directory/tasks.py

   1 from mygpo.podcasts.models import Podcast
   2 from mygpo.subscriptions.models import Subscription
   3 from mygpo.celery import celery
   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         podcast.subscribers = Subscription.objects.filter(podcast=podcast)\
  15                                                   .order_by('user')\
  16                                                   .distinct('user')\
  17                                                   .count()
  18         podcast.save()
  19
  20     #TODO: which exceptions?
  21     except Exception as ex:
  22         raise update_podcast_subscribers.retry(exc=ex)