diff options
| author | Mike Bayer <mike_mp@zzzcomputing.com> | 2020-12-04 16:26:44 -0500 |
|---|---|---|
| committer | Mike Bayer <mike_mp@zzzcomputing.com> | 2020-12-08 08:46:49 -0500 |
| commit | dc60de7c105234b6144cd7c24411abbc3363406e (patch) | |
| tree | 843ff7166813d6c24e1d927dd7af13ce1cfbcf64 /test/ext/asyncio/test_session_py3k.py | |
| parent | 0d7c12735b0a871205c23904320a6f42384df1e8 (diff) | |
| download | sqlalchemy-dc60de7c105234b6144cd7c24411abbc3363406e.tar.gz | |
add aiomysql support
Fixes: #5747
Change-Id: Ia8ad3efe3b50ce75a3bed1e020e1b82acb5f2eda
Diffstat (limited to 'test/ext/asyncio/test_session_py3k.py')
| -rw-r--r-- | test/ext/asyncio/test_session_py3k.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/test/ext/asyncio/test_session_py3k.py b/test/ext/asyncio/test_session_py3k.py index a3b8add67..44e295542 100644 --- a/test/ext/asyncio/test_session_py3k.py +++ b/test/ext/asyncio/test_session_py3k.py @@ -55,6 +55,7 @@ class AsyncSessionQueryTest(AsyncFixture): eq_(result.scalars().all(), self.static.user_address_result) @async_test + @testing.requires.independent_cursors async def test_stream_partitions(self, async_session): User = self.classes.User @@ -99,6 +100,7 @@ class AsyncSessionTransactionTest(AsyncFixture): result = await async_session.execute(select(User)) eq_(result.scalar(), u1) + await outer_conn.rollback() eq_(await outer_conn.scalar(select(func.count(User.id))), 1) @async_test @@ -118,6 +120,7 @@ class AsyncSessionTransactionTest(AsyncFixture): await async_session.commit() + await outer_conn.rollback() eq_(await outer_conn.scalar(select(func.count(User.id))), 1) @async_test @@ -139,6 +142,7 @@ class AsyncSessionTransactionTest(AsyncFixture): finally: await trans.commit() + await outer_conn.rollback() eq_(await outer_conn.scalar(select(func.count(User.id))), 1) @async_test |