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