Merge pull request Parallels#49 from codebynumbers/master

Create redis connection at start on app launch

rq_dashboard/__init__.py

@@ -11,6 +11,7 @@ def __init__(self, app=None, url_prefix='/rq', auth_handler=None):
         else:
             self.app = None
         self.auth_handler = auth_handler
+        self.redis_conn = None
 
     def init_app(self, app):
         """Initializes the RQ-Dashboard for the specified application."""

rq_dashboard/dashboard.py

@@ -1,6 +1,6 @@
 from redis import Redis
 from redis import from_url
-from rq import push_connection
+from rq import push_connection, pop_connection
 from functools import wraps
 import times
 from flask import Blueprint
@@ -27,16 +27,26 @@ def authentication_hook():
     if auth_handler and not auth_handler():
         abort(401)
 
+
 @dashboard.before_app_first_request
 def setup_rq_connection():
     if current_app.config.get('REDIS_URL'):
-        redis_conn = from_url(current_app.config.get('REDIS_URL'))
+        current_app.redis_conn = from_url(current_app.config.get('REDIS_URL'))
     else:
-        redis_conn = Redis(host=current_app.config.get('REDIS_HOST', 'localhost'),
+        current_app.redis_conn = Redis(host=current_app.config.get('REDIS_HOST', 'localhost'),
                        port=current_app.config.get('REDIS_PORT', 6379),
                        password=current_app.config.get('REDIS_PASSWORD', None),
                        db=current_app.config.get('REDIS_DB', 0))
-    push_connection(redis_conn)
+
+
+@dashboard.before_request
+def push_rq_connection():
+    push_connection(current_app.redis_conn)
+
+
+@dashboard.teardown_request
+def pop_rq_connection(exception=None):
+    pop_connection()
 
 
 def jsonify(f):