From 13c4ebbc15e04f3a11d82d460f2e95f1852f97c6 Mon Sep 17 00:00:00 2001
From: Yuval Adam <yuv.adm@gmail.com>
Date: Fri, 16 Nov 2012 11:41:25 +0200
Subject: Celery schedule and print fib task

---
 tasks.py | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

(limited to 'tasks.py')

diff --git a/tasks.py b/tasks.py
index 182a9d3..e65a256 100644
--- a/tasks.py
+++ b/tasks.py
@@ -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))
-- 
cgit v1.3.1