Skip to content

Commit

Permalink
chore: connection managment refactoring #214
Browse files Browse the repository at this point in the history
  • Loading branch information
kalombos authored Apr 12, 2024
1 parent c93271e commit 8da99b2
Show file tree
Hide file tree
Showing 3 changed files with 106 additions and 184 deletions.
8 changes: 4 additions & 4 deletions load-testing/app.py
Original file line number Diff line number Diff line change
Expand Up @@ -85,7 +85,7 @@ async def lifespan(app: FastAPI):


@app.get("/select")
async def test():
async def select():
try:
await manager.execute(MySimplestModel.select())
except Exception as e:
Expand All @@ -105,7 +105,7 @@ async def nested_atomic():


@app.get("/transaction")
async def test():
async def transaction():
try:
async with manager.transaction():
await manager.execute(MySimplestModel.update(id=1))
Expand All @@ -117,7 +117,7 @@ async def test():


@app.get("/atomic")
async def test():
async def atomic():
try:
async with manager.atomic():
await manager.execute(MySimplestModel.update(id=1))
Expand All @@ -129,7 +129,7 @@ async def test():


@app.get("/recreate_pool")
async def test():
async def atomic():
await manager.database.close_async()
await manager.database.connect_async()

Expand Down
Loading

0 comments on commit 8da99b2

Please sign in to comment.