mygpo/api/tasks.py

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