diff options
Diffstat (limited to 'tasks.py')
| -rw-r--r-- | tasks.py | 17 |
1 files changed, 16 insertions, 1 deletions
@@ -1,11 +1,26 @@ +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), + }, +} + -@celery.task 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)) |
