From e1e0eb3f6de90436e2c40bee9bd0b517970709cb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Wed, 6 May 2020 18:50:06 +0200
Subject: [PATCH] fix tests for 1.0.5
---
tests/test_clustering/test_things.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/tests/test_clustering/test_things.py b/tests/test_clustering/test_things.py
index 7222a2a..3369eb2 100644
--- a/tests/test_clustering/test_things.py
+++ b/tests/test_clustering/test_things.py
@@ -17,13 +17,14 @@ logging.basicConfig(level=logging.DEBUG)
class TestConnecting(unittest.TestCase):
def test_on_fail(self):
+ """Assert that on_fail doesn't fire if the cluster fails to connect"""
q = {'failed': False}
c = Cluster(
NodeDefinition(os.environ.get('AMQP_HOST', '127.0.0.1'), 'xguest', 'xguest', heartbeat=20),
on_fail=lambda: q.update(failed=True))
self.assertRaises(ConnectionDead, c.start)
c.shutdown()
- self.assertTrue(q['failed'])
+ self.assertFalse(q['failed'])
def test_on_clean(self):
q = {'failed': False}
--
GitLab