mygpo/admin/tasks.py

   1 from mygpo.cel import celery
   2 from mygpo.maintenance.merge import PodcastMerger
   3 from mygpo.db.couchdb.podcast import podcasts_by_id
   4 from mygpo.counter import Counter
   5
   6
   7 @celery.task
   8 def merge_podcasts(podcast_ids, num_groups):
   9     """ Task to merge some podcasts"""
  10
  11     podcasts = podcasts_by_id(podcast_ids)
  12
  13     actions = Counter()
  14
  15     pm = PodcastMerger(podcasts, actions, num_groups)
  16     pm.merge
  17
  18     return actions, podcasts[0]