From 6edc68269d1ba443e33f66ad48f52b47befad8b0 Mon Sep 17 00:00:00 2001 From: Yuval Adam Date: Fri, 16 Nov 2012 11:53:22 +0200 Subject: Use the periodic_task decorator --- tasks.py | 15 ++++----------- 1 file changed, 4 insertions(+), 11 deletions(-) (limited to 'tasks.py') diff --git a/tasks.py b/tasks.py index 5ece5fc..3eddf63 100644 --- a/tasks.py +++ b/tasks.py @@ -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)) -- cgit v1.3.1