mygpo/admin/tasks.py

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