# -*- coding: utf-8 -*- from celery.task import periodic_task @periodic_task(run_every=timedelta(hours=1), queue='encoding') def subtitles_user(**kwargs): import annotation.models from user.models import User u = User.object.get(username='subtitles') annotation.models.Annotation.objects.filter(layer='subtitles').exclude(user=u).update(user=u)