Fix a mis-reference in create_async_engine().

Fixes #5529

diff --git a/lib/sqlalchemy/ext/asyncio/engine.py b/lib/sqlalchemy/ext/asyncio/engine.py
index 2d9198d169cb09b5dcec2169ef42bb91ed9682a6..619cf85086318b51eba0ce36d03971dbc36fb07f 100644 (file)
--- a/lib/sqlalchemy/ext/asyncio/engine.py
+++ b/lib/sqlalchemy/ext/asyncio/engine.py
@@ -31,7 +31,7 @@ def create_async_engine(*arg, **kw):
     """
 
     if kw.get("server_side_cursors", False):
-        raise exc.AsyncMethodRequired(
+        raise async_exc.AsyncMethodRequired(
             "Can't set server_side_cursors for async engine globally; "
             "use the connection.stream() method for an async "
             "streaming result set"

diff --git a/test/ext/asyncio/test_engine_py3k.py b/test/ext/asyncio/test_engine_py3k.py
index ec513cb649d2b2325bd99f8addd9732df34681e5..91cb45aace8a3cb3debd1acbafc48667fb6d0ffa 100644 (file)
--- a/test/ext/asyncio/test_engine_py3k.py
+++ b/test/ext/asyncio/test_engine_py3k.py
@@ -135,6 +135,16 @@ class AsyncEngineTest(EngineFixture):
                 trans.rollback(),
             )
 
+    @async_test
+    async def test_create_async_engine_server_side_cursor(self, async_engine):
+        testing.assert_raises_message(
+            asyncio_exc.AsyncMethodRequired,
+            "Can't set server_side_cursors for async engine globally",
+            create_async_engine,
+            testing.db.url,
+            server_side_cursors=True,
+        )
+
 
 class AsyncResultTest(EngineFixture):
     @testing.combinations(