# coding=utf-8 from celery.task import periodic_task from datetime import timedelta, datetime from practice.models import Workshop @periodic_task(run_every=timedelta(minutes=1)) def open_resolves(): for resolve in Workshop.objects.filter(open_resolve=False, will_open_resolve__lte=datetime.now()).exclude(resolve=''): resolve.open_resolve = True resolve.save()