docs fix

Author: krylosov-aa

README.md

@@ -110,7 +110,7 @@ from contextlib import asynccontextmanager
 from typing import Any, AsyncGenerator
 from fastapi import FastAPI
 
-from .database import master
+from database import master
 
 
 @asynccontextmanager
@@ -195,8 +195,8 @@ from sqlalchemy import insert
 
 from context_async_sqlalchemy import db_session
 
-from ..database import master
-from ..models import ExampleTable
+from database import master
+from models import ExampleTable
 
 
 async def handler_with_db_session() -> None:

exmaples/fastapi_example/routes/multiple_session_usage.py

@@ -5,6 +5,8 @@
     close_db_session,
     commit_db_session,
     db_session,
+    new_non_ctx_atomic_session,
+    new_non_ctx_session,
     run_in_new_ctx,
 )
 from sqlalchemy import insert
@@ -21,9 +23,8 @@ async def handler_multiple_sessions() -> None:
     await asyncio.gather(
         run_in_new_ctx(_insert),
         run_in_new_ctx(_insert_manual),
-        run_in_new_ctx(_insert),
-        run_in_new_ctx(_insert_manual),
-        run_in_new_ctx(_insert),
+        _insert_non_ctx(),
+        _insert_non_ctx_manual(),
     )
 
 
@@ -41,3 +42,16 @@ async def _insert_manual() -> None:
 
     # You can manually close the session if you want, but it is not necessary
     await close_db_session(master)
+
+
+async def _insert_non_ctx() -> None:
+    async with new_non_ctx_atomic_session(master) as session:
+        stmt = insert(ExampleTable).values(text="example_multiple_sessions")
+        await session.execute(stmt)
+
+
+async def _insert_non_ctx_manual() -> None:
+    async with new_non_ctx_session(master) as session:
+        stmt = insert(ExampleTable).values(text="example_multiple_sessions")
+        await session.execute(stmt)
+        await session.commit()

exmaples/fastapi_example/tests/non_transactional/test_routes.py

@@ -98,7 +98,7 @@ async def test_example_multiple_sessions(
 
     result = await db_session_test.execute(select(ExampleTable))
     rows = result.scalars().all()
-    assert len(rows) == 5
+    assert len(rows) == 4
     for row in rows:
         assert row.text == "example_multiple_sessions"