# -*- coding: utf-8 -*-
# vi:si:et:sw=4:sts=4:ts=4
from datetime import timedelta

from celery.task import task, periodic_task
from celery.task.schedules import crontab


from models import Event


@periodic_task(run_every=crontab(hour=7, minute=30), queue='encoding')
def update_all_matches(**kwargs):
    ids = [e['id'] for e in Event.objects.all().values('id')]
    for i in ids:
        e = Event.objects.get(pk=i)
        e.update_matches()

@task(ignore_resulsts=True, queue='default')
def update_matches(eventId):
    event = Event.objects.get(pk=eventId)
    event.update_matches()