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

Fixes connectionerror bug on 2.7

Browse Source
This commit is contained in:
Ilan Steemers
2015-09-02 20:17:44 +02:00
parent dfb1b03cd0
commit e22980834c
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/brokers/disque.py
+1 -1
View File
@@ -48,4 +48,4 @@ class Disque(Broker):
return redis_client return redis_client
except redis.exceptions.ConnectionError: except redis.exceptions.ConnectionError:
continue continue
raise ConnectionError('Could not connect to any Disque nodes') raise redis.exceptions.ConnectionError('Could not connect to any Disque nodes')
django_q/tests/test_brokers.py
+2 -1
View File
@@ -1,6 +1,7 @@
from time import sleep from time import sleep
import pytest import pytest
import os import os
import redis
from django_q.conf import Conf from django_q.conf import Conf
from django_q.brokers import get_broker, Broker from django_q.brokers import get_broker, Broker
@@ -58,7 +59,7 @@ def test_disque():
sleep(1.5) sleep(1.5)
assert broker.queue_size() == 0 assert broker.queue_size() == 0
Conf.DISQUE = ['127.0.0.1:7712', '127.0.0.1:7713'] Conf.DISQUE = ['127.0.0.1:7712', '127.0.0.1:7713']
with pytest.raises(ConnectionError): with pytest.raises(redis.exceptions.ConnectionError):
broker.get_connection() broker.get_connection()
broker.delete_queue() broker.delete_queue()
assert broker.queue_size() == 0 assert broker.queue_size() == 0