diff --git a/tests/test_clustering/test_things.py b/tests/test_clustering/test_things.py
index 7222a2abba00920238b12abf407290b716f5e95c..3369eb20d324948fdcdc5d654dda2d16911ff759 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}