Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions src/age_plotter/services/age_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,10 +19,10 @@ async def connect(self) -> None:
port=self.config.port,
dbname=self.config.database,
user=self.config.username,
password=self.config.password,
password=self.config.password
)
# Load AGE extension
await self.conn.execute("LOAD 'age';")
await self.conn.execute("LOAD '$libdir/plugins/age.so';")
await self.conn.execute("SET search_path = ag_catalog, '$user', public;")

async def test_connection(self) -> bool:
Expand Down
2 changes: 1 addition & 1 deletion src/age_plotter/services/query_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -414,7 +414,7 @@ async def _execute_age(

try:
# Load AGE extension
await conn.execute(sql.SQL("LOAD 'age'"))
await conn.execute(sql.SQL("LOAD '$libdir/plugins/age.so'"))
await conn.execute(sql.SQL("SET search_path = ag_catalog, '$user', public"))

# Get backend PID for cancellation
Expand Down
2 changes: 1 addition & 1 deletion src/age_plotter/services/schema_introspector.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ async def introspect_age(config: AgeConnection) -> GraphSchema:
password=config.password,
)
try:
await conn.execute("LOAD 'age';")
await conn.execute("LOAD '$libdir/plugins/age.so';")
await conn.execute("SET search_path = ag_catalog, '$user', public;")

# Get graph OID
Expand Down