from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from celery.schedules import crontab

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'unlimited_leads.settings')

app = Celery('unlimited_leads')
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()

app.conf.beat_schedule = {
    "reset-user-usage-limit": {
        "task": "user.tasks.reset_user_usage_limit",
        "schedule": crontab(hour=0, minute=0),
    },
    "notify-saved-search-new-records": {
        "task": "user.tasks.notify_saved_search_new_records",
        "schedule": crontab(minute=0, hour='*/6'),
    }
}