from celery import Celery
import os

os.environ.setdefault("DJANGO_SETTINGS_MODULE", "preports.settings")
app = Celery('preports')
app.config_from_object("django.conf:settings", namespace="CELERY")
app.autodiscover_tasks()


@app.on_after_finalize.connect
def setup_periodical_tasks(sender, **kwargs):
    from api.tasks import send_due_reports
    sender.add_periodic_task(10.0, send_due_reports.s(),
                             name="Send due Programmed Reports.")