Dreamspace/adventures
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(data) Fix for new pgsql lib version.

Browse Source
This commit is contained in:
Interitio
2025-06-06 22:25:05 +10:00
parent d271248812
commit a7afa5001d
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/data/connector.py
View File

@@ -47,8 +47,8 @@ class Connector:
return AsyncConnectionPool( return AsyncConnectionPool(
self._conn_args, self._conn_args,
open=False, open=False,
min_size=4, min_size=1,
max_size=8, max_size=4,
configure=self._setup_connection, configure=self._setup_connection,
kwargs=self._conn_kwargs kwargs=self._conn_kwargs
) )

4
src/data/cursor.py
View File

@@ -3,7 +3,7 @@ from typing import Optional
from psycopg import AsyncCursor, sql from psycopg import AsyncCursor, sql
from psycopg.abc import Query, Params from psycopg.abc import Query, Params
from psycopg._encodings import pgconn_encoding from psycopg._encodings import conn_encoding
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@@ -15,7 +15,7 @@ class AsyncLoggingCursor(AsyncCursor):
elif isinstance(query, (sql.SQL, sql.Composed)): elif isinstance(query, (sql.SQL, sql.Composed)):
msg = query.as_string(self) msg = query.as_string(self)
elif isinstance(query, bytes): elif isinstance(query, bytes):
msg = query.decode(pgconn_encoding(self._conn.pgconn), 'replace') msg = query.decode(conn_encoding(self._conn.pgconn), 'replace')
else: else:
msg = repr(query) msg = repr(query)
return msg return msg