tasks.py


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

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))