mirror of
https://github.com/danswer-ai/danswer.git
synced 2025-06-30 09:40:50 +02:00
Add trace for db session creation
This commit is contained in:
@ -2,6 +2,7 @@ from collections.abc import AsyncGenerator
|
|||||||
from collections.abc import Generator
|
from collections.abc import Generator
|
||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
|
||||||
|
from ddtrace import tracer
|
||||||
from sqlalchemy import text
|
from sqlalchemy import text
|
||||||
from sqlalchemy.engine import create_engine
|
from sqlalchemy.engine import create_engine
|
||||||
from sqlalchemy.engine import Engine
|
from sqlalchemy.engine import Engine
|
||||||
@ -69,8 +70,9 @@ def get_sqlalchemy_async_engine() -> AsyncEngine:
|
|||||||
|
|
||||||
|
|
||||||
def get_session() -> Generator[Session, None, None]:
|
def get_session() -> Generator[Session, None, None]:
|
||||||
with Session(get_sqlalchemy_engine(), expire_on_commit=False) as session:
|
with tracer.trace("db.get_session"):
|
||||||
yield session
|
with Session(get_sqlalchemy_engine(), expire_on_commit=False) as session:
|
||||||
|
yield session
|
||||||
|
|
||||||
|
|
||||||
async def get_async_session() -> AsyncGenerator[AsyncSession, None]:
|
async def get_async_session() -> AsyncGenerator[AsyncSession, None]:
|
||||||
|
Reference in New Issue
Block a user