Skip to content

Commit 78009c0

Browse files
committed
Look at the Dialect for SQLAlchemy, and small cleanup
1 parent c4ac4ee commit 78009c0

2 files changed

Lines changed: 2 additions & 3 deletions

File tree

sentry_sdk/integrations/asyncpg.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,7 @@ async def _inner(*args: "Any", **kwargs: "Any") -> "T":
199199

200200
def _set_db_data(span: "Span", conn: "Any") -> None:
201201
span.set_data(SPANDATA.DB_SYSTEM, "postgresql")
202+
span.set_data(SPANDATA.DB_DRIVER_NAME, "asyncpg")
202203

203204
addr = conn._addr
204205
if addr:
@@ -215,5 +216,3 @@ def _set_db_data(span: "Span", conn: "Any") -> None:
215216
user = conn._params.user
216217
if user:
217218
span.set_data(SPANDATA.DB_USER, user)
218-
219-
span.set_data(SPANDATA.DB_DRIVER_NAME, "asyncpg")

sentry_sdk/integrations/sqlalchemy.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -138,7 +138,7 @@ def _set_db_data(span: "Span", conn: "Any") -> None:
138138
span.set_data(SPANDATA.DB_SYSTEM, db_system)
139139

140140
try:
141-
driver = conn.engine.driver
141+
driver = conn.dialect.driver
142142
if driver:
143143
span.set_data(SPANDATA.DB_DRIVER_NAME, driver)
144144
except Exception:

0 commit comments

Comments
 (0)