def test_captured_exception(self):
        from kazoo.handlers.utils import capture_exceptions

        mock_handler = mock.Mock()
        async = self._makeOne(mock_handler)

        @capture_exceptions(async)
        def exceptional_function():
            return 0/1

        exceptional_function()

        assert_raises(ZeroDivisionError, async.get)
dataset/ETHPy150Open cloudera/hue/desktop/core/ext-py/kazoo-2.0/kazoo/tests/test_threading_handler.py/TestThreadingAsync.test_captured_exception/swapped operands of `/`