Use get_queue function from flask-rq

Author: sandlerben

app/account/views.py

@@ -5,6 +5,7 @@
     logout_user,
     current_user
 )
+from flask.ext.rq import get_queue
 from . import account
 from .. import db
 from ..email import send_async_email
@@ -18,7 +19,6 @@
     RequestResetPasswordForm,
     ResetPasswordForm
 )
-from app import redis_queue
 
 
 @account.route('/login', methods=['GET', 'POST'])
@@ -50,7 +50,7 @@ def register():
         db.session.commit()
         token = user.generate_confirmation_token()
         confirm_link = url_for('account.confirm', token=token, _external=True)
-        redis_queue.enqueue(
+        get_queue().enqueue(
             send_async_email,
             recipient=user.email,
             subject='Confirm Your Account',
@@ -92,7 +92,7 @@ def reset_password_request():
             token = user.generate_password_reset_token()
             reset_link = url_for('account.reset_password', token=token,
                                  _external=True)
-            redis_queue.enqueue(
+            get_queue().enqueue(
                 send_async_email,
                 recipient=user.email,
                 subject='Reset Your Password',
@@ -157,7 +157,7 @@ def change_email_request():
             token = current_user.generate_email_change_token(new_email)
             change_email_link = url_for('account.change_email', token=token,
                                         _external=True)
-            redis_queue.enqueue(
+            get_queue().enqueue(
                 send_async_email,
                 recipient=new_email,
                 subject='Confirm Your New Email',
@@ -192,7 +192,7 @@ def confirm_request():
     """Respond to new user's request to confirm their account."""
     token = current_user.generate_confirmation_token()
     confirm_link = url_for('account.confirm', token=token, _external=True)
-    redis_queue.enqueue(
+    get_queue().enqueue(
         send_async_email,
         recipient=current_user.email,
         subject='Confirm Your Account',
@@ -256,7 +256,7 @@ def join_from_invite(user_id, token):
         token = new_user.generate_confirmation_token()
         invite_link = url_for('account.join_from_invite', user_id=user_id,
                               token=token, _external=True)
-        redis_queue.enqueue(
+        get_queue().enqueue(
             send_async_email,
             recipient=new_user.email,
             subject='You Are Invited To Join',

app/admin/views.py

@@ -2,6 +2,7 @@
 
 from flask import render_template, abort, redirect, flash, url_for
 from flask.ext.login import login_required, current_user
+from flask.ext.rq import get_queue
 
 from forms import (
     ChangeUserEmailForm,
@@ -13,7 +14,6 @@
 from ..models import User, Role
 from .. import db
 from ..email import send_async_email
-from app import redis_queue
 
 
 @admin.route('/')
@@ -59,7 +59,7 @@ def invite_user():
         token = user.generate_confirmation_token()
         invite_link = url_for('account.join_from_invite', user_id=user.id,
                               token=token, _external=True)
-        redis_queue.enqueue(
+        get_queue().enqueue(
             send_async_email,
             recipient=user.email,
             subject='You Are Invited To Join',