import logging from celery import Celery from celery.schedules import crontab celery = Celery('tasks', broker='redis://localhost') CELERYBEAT_SCHEDULE = { 'every-ten-secs': { 'task': 'tasks.print_fib', 'schedule': crontab(minute='*/1'), 'args': (30), }, } def fib(n): if n > 1: return fib(n - 1) + fib(n - 2) else: return 1 @celery.task def print_fib(n): logging.info(fib(n))