Periodic tasks with celery

periodic_task.py

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

from .models import send_all

# Every ten minutes
@periodic_task(run_every=crontab(hour="*", minute="*/10", day_of_week="*"))
def send_newsletter():
    print("Sending Newsletters")
    send_all()

# Every minute
@periodic_task(run_every=crontab(hour="*", minute="*", day_of_week="*"))
def every_minute():
    print("Every minute, I am called :(")

# Every minute
@periodic_task(run_every=crontab(minute="*/1"))
def hello_world():
    print("Hello world")

celery.decorators will be removed in Celery 5.0