(self, async_engine)
| 1547 | |
| 1548 | @async_test |
| 1549 | async def test_sync_driver_run_sync(self, async_engine): |
| 1550 | async with async_engine.connect() as conn: |
| 1551 | res = await conn.run_sync( |
| 1552 | lambda conn: conn.scalar(text("select 1")) |
| 1553 | ) |
| 1554 | assert res == 1 |
| 1555 | assert await conn.run_sync(lambda _: 2) == 2 |
| 1556 | |
| 1557 | |
| 1558 | class AsyncProxyTest(EngineFixture, fixtures.TestBase): |