mygpo/episodestates/tasks.py

   1 from celery.utils.log import get_task_logger
   2
   3 from mygpo.celery import celery
   4 from mygpo.episodestates.models import EpisodeState
   5
   6 logger = get_task_logger(__name__)
   7
   8
   9 @celery.task
  10 def update_episode_state(historyentry):
  11     """ Updates the episode state with the saved EpisodeHistoryEntry """
  12
  13     user = historyentry.user
  14     episode = historyentry.episode
  15
  16     logger.info('Updating Episode State for {user} / {episode}'.format(
  17         user=user, episode=episode))
  18
  19     state = EpisodeState.objects.update_or_create(
  20         user=user,
  21         episode=episode,
  22         defaults={
  23             'action': historyentry.action,
  24             'timestamp': historyentry.timestamp,
  25         }
  26     )