o

tests/test_clustering/test_things.py

@@ -24,11 +24,7 @@ class TestConnecting(unittest.TestCase):
 
     def test_on_clean(self):
         q = {'failed': False}
-        def on_fail():
-            raise Exception()
-            q['failed'] = True
-
-        c = Cluster([NODE], on_fail=on_fail)
+        c = Cluster([NODE], on_fail=lambda: q.update(failed=True))
         c.start(wait=True)
         c.shutdown()
         time.sleep(5)