Use the periodic_task decorator

1 files changed, 4 insertions, 11 deletions

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