Skip to content

Commit 638cc00

Browse files
committed
fix: add pg_catalog to gdb status queries
1 parent 3e772e9 commit 638cc00

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

aws_advanced_python_wrapper/database_dialect.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -628,15 +628,15 @@ def get_host_list_provider_supplier(self, plugin_service: PluginService) -> Call
628628

629629

630630
class GlobalAuroraPgDialect(AuroraPgDialect, GlobalAuroraTopologyDialect):
631-
_GLOBAL_STATUS_TABLE_EXISTS_QUERY = "select 'aurora_global_db_status'::regproc"
632-
_GLOBAL_INSTANCE_STATUS_EXISTS_QUERY = "select 'aurora_global_db_instance_status'::regproc"
631+
_GLOBAL_STATUS_TABLE_EXISTS_QUERY = "select 'pg_catalog.aurora_global_db_status'::regproc"
632+
_GLOBAL_INSTANCE_STATUS_EXISTS_QUERY = "select 'pg_catalog.aurora_global_db_instance_status'::regproc"
633633
_TOPOLOGY_QUERY = \
634634
("SELECT SERVER_ID, CASE WHEN SESSION_ID = 'MASTER_SESSION_ID' THEN TRUE ELSE FALSE END, "
635635
"VISIBILITY_LAG_IN_MSEC, AWS_REGION "
636-
"FROM aurora_global_db_instance_status()")
637-
_REGION_COUNT_QUERY = "SELECT count(1) FROM aurora_global_db_status()"
636+
"FROM pg_catalog.aurora_global_db_instance_status()")
637+
_REGION_COUNT_QUERY = "SELECT count(1) FROM pg_catalog.aurora_global_db_status()"
638638
_REGION_BY_INSTANCE_ID_QUERY = \
639-
"SELECT AWS_REGION FROM aurora_global_db_instance_status() WHERE SERVER_ID = %s"
639+
"SELECT AWS_REGION FROM pg_catalog.aurora_global_db_instance_status() WHERE SERVER_ID = %s"
640640

641641
@property
642642
def dialect_update_candidates(self) -> Optional[Tuple[DialectCode, ...]]:

0 commit comments

Comments
 (0)