|
|
@ -12,34 +12,34 @@ def testjob(name=None):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
class RQTestCase(unittest.TestCase):
|
|
|
|
class RQTestCase(unittest.TestCase):
|
|
|
|
def setUp(self):
|
|
|
|
@classmethod
|
|
|
|
super(RQTestCase, self).setUp()
|
|
|
|
def setUpClass(cls):
|
|
|
|
|
|
|
|
|
|
|
|
# Set up connection to Redis
|
|
|
|
# Set up connection to Redis
|
|
|
|
testconn = Redis()
|
|
|
|
testconn = Redis()
|
|
|
|
conn.push(testconn)
|
|
|
|
conn.push(testconn)
|
|
|
|
|
|
|
|
|
|
|
|
# Flush beforewards (we like our hygiene)
|
|
|
|
|
|
|
|
conn.flushdb()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# Store the connection (for sanity checking)
|
|
|
|
# Store the connection (for sanity checking)
|
|
|
|
self.testconn = testconn
|
|
|
|
cls.testconn = testconn
|
|
|
|
|
|
|
|
|
|
|
|
# Shut up logbook
|
|
|
|
# Shut up logbook
|
|
|
|
self.log_handler = NullHandler()
|
|
|
|
cls.log_handler = NullHandler()
|
|
|
|
self.log_handler.push_thread()
|
|
|
|
cls.log_handler.push_thread()
|
|
|
|
|
|
|
|
|
|
|
|
def tearDown(self):
|
|
|
|
def setUp(self):
|
|
|
|
self.log_handler.pop_thread()
|
|
|
|
# Flush beforewards (we like our hygiene)
|
|
|
|
|
|
|
|
conn.flushdb()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def tearDown(self):
|
|
|
|
# Flush afterwards
|
|
|
|
# Flush afterwards
|
|
|
|
conn.flushdb()
|
|
|
|
conn.flushdb()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@classmethod
|
|
|
|
|
|
|
|
def tearDownClass(cls):
|
|
|
|
|
|
|
|
cls.log_handler.pop_thread()
|
|
|
|
|
|
|
|
|
|
|
|
# Pop the connection to Redis
|
|
|
|
# Pop the connection to Redis
|
|
|
|
testconn = conn.pop()
|
|
|
|
testconn = conn.pop()
|
|
|
|
assert testconn == self.testconn, 'Wow, something really nasty happened to the Redis connection stack. Check your setup.'
|
|
|
|
assert testconn == cls.testconn, 'Wow, something really nasty happened to the Redis connection stack. Check your setup.'
|
|
|
|
|
|
|
|
|
|
|
|
super(RQTestCase, self).tearDown()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def assertQueueContains(self, queue, that_func):
|
|
|
|
def assertQueueContains(self, queue, that_func):
|
|
|
|