diff options
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 |