From 019c80e1c556190a717693ea66e16e573e37f86f Mon Sep 17 00:00:00 2001 From: Interitio Date: Tue, 23 Jul 2024 21:02:15 +1000 Subject: [PATCH] fix: Update internal psycopg encoding util. --- src/data/cursor.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/data/cursor.py b/src/data/cursor.py index 5e01a8d1..5d183e0b 100644 --- a/src/data/cursor.py +++ b/src/data/cursor.py @@ -3,7 +3,7 @@ from typing import Optional from psycopg import AsyncCursor, sql from psycopg.abc import Query, Params -from psycopg._encodings import pgconn_encoding +from psycopg._encodings import conn_encoding logger = logging.getLogger(__name__) @@ -15,7 +15,7 @@ class AsyncLoggingCursor(AsyncCursor): elif isinstance(query, (sql.SQL, sql.Composed)): msg = query.as_string(self) elif isinstance(query, bytes): - msg = query.decode(pgconn_encoding(self._conn.pgconn), 'replace') + msg = query.decode(conn_encoding(self._conn.pgconn), 'replace') else: msg = repr(query) return msg