1 from celery
.utils
.log
import get_task_logger
3 from mygpo
.cel
import celery
4 from mygpo
.api
.advanced
import update_episodes
6 logger
= get_task_logger(__name__
)
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
)
14 # celery-based handler for episode-actions
15 episode_actions_celery_handler
= import_episode_actions
.delay