highperfocused/danswer
1
0
Fork 0
mirror of https://github.com/danswer-ai/danswer.git synced 2025-09-17 19:20:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #3131 from danswer-ai/bugfix/session_text

Browse Source 
use text()
This commit is contained in:
rkuo-danswer
2024-11-13 20:24:14 -08:00
committed by GitHub
parent 7c841051ed 65a205d488
commit 21d5cc43f8
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
backend/danswer/db/engine.py
View File

@@ -319,7 +319,9 @@ async def get_async_session_with_tenant(
await session.execute(text(f'SET search_path = "{tenant_id}"')) await session.execute(text(f'SET search_path = "{tenant_id}"'))
if POSTGRES_IDLE_SESSIONS_TIMEOUT: if POSTGRES_IDLE_SESSIONS_TIMEOUT:
await session.execute( await session.execute(
f"SET SESSION idle_in_transaction_session_timeout = {POSTGRES_IDLE_SESSIONS_TIMEOUT}" text(
f"SET SESSION idle_in_transaction_session_timeout = {POSTGRES_IDLE_SESSIONS_TIMEOUT}"
)
) )
except Exception: except Exception:
logger.exception("Error setting search_path.") logger.exception("Error setting search_path.")
@@ -380,7 +382,9 @@ def get_session_with_tenant(
cursor.execute(f'SET search_path = "{tenant_id}"') cursor.execute(f'SET search_path = "{tenant_id}"')
if POSTGRES_IDLE_SESSIONS_TIMEOUT: if POSTGRES_IDLE_SESSIONS_TIMEOUT:
cursor.execute( cursor.execute(
f"SET SESSION idle_in_transaction_session_timeout = {POSTGRES_IDLE_SESSIONS_TIMEOUT}" text(
f"SET SESSION idle_in_transaction_session_timeout = {POSTGRES_IDLE_SESSIONS_TIMEOUT}"
)
) )
finally: finally:
cursor.close() cursor.close()