diff options
Diffstat (limited to 'tasks.py')
| -rw-r--r-- | tasks.py | 15 |
1 files changed, 4 insertions, 11 deletions
@@ -1,18 +1,11 @@ import logging from celery import Celery +from celery.task import periodic_task from datetime import timedelta celery = Celery('tasks', broker='redis://localhost') -CELERYBEAT_SCHEDULE = { - 'every-ten-secs': { - 'task': 'tasks.print_fib', - 'schedule': timedelta(seconds=10), - 'args': (30), - }, -} - def fib(n): if n > 1: @@ -21,6 +14,6 @@ def fib(n): return 1 -@celery.task -def print_fib(n): - logging.info(fib(n)) +@periodic_task(run_every=timedelta(seconds=10)) +def print_fib(): + logging.info(fib(30)) |
