fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-09 07:18:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Resets SQS conf in case of test failure

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-09 18:59:24 +02:00
parent d7ce945f03
commit e4a5951f12
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/tests/test_cluster.py
+2
View File
@@ -18,6 +18,7 @@ from django_q.status import Stat
from django_q.brokers import get_broker from django_q.brokers import get_broker
from .tasks import multiply from .tasks import multiply
class WordClass(object): class WordClass(object):
def __init__(self): def __init__(self):
self.word_list = DEFAULT_WORDLIST self.word_list = DEFAULT_WORDLIST
@@ -30,6 +31,7 @@ class WordClass(object):
def broker(): def broker():
Conf.DISQUE_NODES = None Conf.DISQUE_NODES = None
Conf.IRON_MQ = None Conf.IRON_MQ = None
Conf.SQS = None
Conf.DJANGO_REDIS = 'default' Conf.DJANGO_REDIS = 'default'
return get_broker() return get_broker()
django_q/tests/test_scheduler.py
+4
View File
@@ -14,6 +14,10 @@ from django_q.tasks import Schedule, fetch, schedule as create_schedule, queue_s
@pytest.fixture @pytest.fixture
def broker(): def broker():
Conf.DISQUE_NODES = None
Conf.IRON_MQ = None
Conf.SQS = None
Conf.DJANGO_REDIS = 'default'
return get_broker() return get_broker()