We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e2bad34 commit f89a3dbCopy full SHA for f89a3db
sdk/python/feast/infra/utils/postgres/connection_utils.py
@@ -68,12 +68,15 @@ def _get_conninfo(config: PostgreSQLConfig) -> str:
68
69
def _get_conn_kwargs(config: PostgreSQLConfig) -> Dict[str, Any]:
70
"""Get the additional `kwargs` required for connection objects."""
71
+ search_path = (config.db_schema or config.user).strip()
72
+ if search_path != "public":
73
+ search_path += ",public"
74
return {
75
"sslmode": config.sslmode,
76
"sslkey": config.sslkey_path,
77
"sslcert": config.sslcert_path,
78
"sslrootcert": config.sslrootcert_path,
- "options": "-c search_path={}".format(config.db_schema or config.user),
79
+ "options": "-c search_path={}".format(search_path),
80
}
81
82
0 commit comments