summaryrefslogtreecommitdiff
path: root/tasks.py
diff options
context:
space:
mode:
Diffstat (limited to 'tasks.py')
-rw-r--r--tasks.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/tasks.py b/tasks.py
index 9d6e78d..c08c357 100644
--- a/tasks.py
+++ b/tasks.py
@@ -5,18 +5,21 @@ from celery.task import periodic_task
from datetime import timedelta
from os import environ
+# Fetch the Redis connection string from the env, or use localhost by default
REDIS_URL = environ.get('REDISTOGO_URL', 'redis://localhost')
+# Setup the celery instance under the 'tasks' namespace
celery = Celery('tasks', broker=REDIS_URL)
-
+# Define the fibonacci function for use in our task
def fib(n):
if n > 1:
return fib(n - 1) + fib(n - 2)
else:
return 1
-
+# The periodic task itself, defined by the following decorator
@periodic_task(run_every=timedelta(seconds=10))
def print_fib():
+ # Just log fibonacci(30), no more
logging.info(fib(30))