From 7e7f9ca66bed6a43c7442216ab815686227208e0 Mon Sep 17 00:00:00 2001 From: dv Date: Mon, 4 May 2026 16:51:51 +0300 Subject: [PATCH] =?UTF-8?q?=D1=85=D0=B7=20=D0=BA=D0=B0=D0=BA=D0=BE=D0=B9-?= =?UTF-8?q?=D1=82=D0=BE=20=D0=BF=D1=80=D0=B8=D0=BA=D0=BE=D0=BB=20=D1=81=20?= =?UTF-8?q?=D1=81=D1=81=D0=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/app/services/discovery/db_resolver.py | 8 ++++++-- backend/app/services/object_db.py | 6 ++++-- 2 files changed, 10 insertions(+), 4 deletions(-) diff --git a/backend/app/services/discovery/db_resolver.py b/backend/app/services/discovery/db_resolver.py index 3f49a1a..c0f130e 100644 --- a/backend/app/services/discovery/db_resolver.py +++ b/backend/app/services/discovery/db_resolver.py @@ -106,11 +106,15 @@ async def get_rack_hosts( local_port = listener.get_port() dsn = ( f"host=127.0.0.1 port={local_port} dbname={dbname} " - f"user={user} password={password} connect_timeout=10" + f"user={user} password={password} connect_timeout=10 " + f"sslmode=disable gssencmode=disable" ) return await _fetch_rack_rows(dsn, table) else: - dsn = f"host={host} port={port} dbname={dbname} user={user} password={password} connect_timeout=10" + dsn = ( + f"host={host} port={port} dbname={dbname} user={user} password={password} " + f"connect_timeout=10 sslmode=disable gssencmode=disable" + ) return await _fetch_rack_rows(dsn, table) diff --git a/backend/app/services/object_db.py b/backend/app/services/object_db.py index a7250c5..2bdf4eb 100644 --- a/backend/app/services/object_db.py +++ b/backend/app/services/object_db.py @@ -97,7 +97,8 @@ async def sync_from_object_db(db: AsyncSession, obj: Object) -> SyncResult: local_port = listener.get_port() dsn = ( f"host=127.0.0.1 port={local_port} dbname={obj.db_name} " - f"user={obj.db_user} password={db_password} connect_timeout=10" + f"user={obj.db_user} password={db_password} connect_timeout=10 " + f"sslmode=disable gssencmode=disable" ) remote_rows = await _fetch_rows(dsn, obj.db_table) except Exception as exc: @@ -106,7 +107,8 @@ async def sync_from_object_db(db: AsyncSession, obj: Object) -> SyncResult: else: dsn = ( f"host={obj.db_host} port={obj.db_port or 5432} dbname={obj.db_name} " - f"user={obj.db_user} password={db_password} connect_timeout=10" + f"user={obj.db_user} password={db_password} connect_timeout=10 " + f"sslmode=disable gssencmode=disable" ) try: remote_rows = await _fetch_rows(dsn, obj.db_table)