mygpo/api/tasks.py

   1 from celery.utils.log import get_task_logger
   2
   3 from mygpo.celery import celery
   4 from mygpo.api.advanced import update_episodes
   5
   6 logger = get_task_logger(__name__)
   7
   8
   9 @celery.task(max_retries=5, default_retry_delay=60)
  10 def import_episode_actions(user, actions, upload_ts, ua_string):
  11     logger.info('Importing %d tasks for user %s', len(actions), user)
  12     update_episodes(user, actions, upload_ts, ua_string)
  13
  14 # celery-based handler for episode-actions
  15 episode_actions_celery_handler = import_episode_actions.delay