mygpo/directory/management/commands/update-toplist.py

   1 from optparse import make_option
   2
   3 from django.core.management.base import BaseCommand
   4
   5 from mygpo.utils import progress
   6 from mygpo.db.couchdb.podcast import podcast_count, all_podcasts
   7 from mygpo.directory.tasks import update_podcast_subscribers
   8
   9
  10 class Command(BaseCommand):
  11     """ For each podcast a task is scheduled to update its subscriber count """
  12
  13     option_list = BaseCommand.option_list + (
  14         make_option('--silent', action='store_true', dest='silent',
  15         default=False, help="Don't show any output"),
  16     )
  17
  18     def handle(self, *args, **options):
  19
  20         silent = options.get('silent')
  21
  22         podcasts = all_podcasts()
  23         total = podcast_count()
  24
  25         for n, podcast in enumerate(podcasts):
  26             update_podcast_subscribers.delay(podcast.get_id())
  27
  28             if not silent:
  29                 progress(n, total)