'BlockingConnection: connection context manager closes connection and passes original exception'

def test(self):

    class MyException(Exception, ):
        pass
    with self.assertRaises(MyException):
        with self._connect() as connection:
            self.assertTrue(connection.is_open)
            raise MyException()
    self.assertTrue(connection.is_closed)
