import logging from celery import Celery from celery.task import periodic_task from datetime import timedelta celery = Celery('tasks', broker='redis://localhost') def fib(n): if n > 1: return fib(n - 1) + fib(n - 2) else: return 1 @periodic_task(run_every=timedelta(seconds=10)) def print_fib(): logging.info(fib(30))