constants

Author: joyc-bq

Diff for: aws_advanced_python_wrapper/driver_dialect.py

@@ -37,14 +37,14 @@ class DriverDialect(ABC):
     """
     Driver dialects help the driver-agnostic AWS Python Driver interface with the driver-specific functionality of the underlying Python Driver.
     """
+    _QUERY = "SELECT 1"
 
     _executor: ClassVar[Executor] = ThreadPoolExecutor()
     _dialect_code: str = DriverDialectCodes.GENERIC
     _network_bound_methods: Set[str] = {"*"}
     _read_only: bool = False
     _autocommit: bool = False
     _driver_name: str = "Generic"
-    _query: str = "SELECT 1"
 
     def __init__(self, props: Properties):
         self._props = props
@@ -157,7 +157,7 @@ def transfer_session_state(self, from_conn: Connection, to_conn: Connection):
     def ping(self, conn: Connection) -> bool:
         try:
             with conn.cursor() as cursor:
-                query = _QUERY
+                query = DriverDialect._QUERY
                 self.execute("Cursor.execute", lambda: cursor.execute(query), query, exec_timeout=10)
                 cursor.fetchone()
                 return True

Diff for: aws_advanced_python_wrapper/host_monitoring_plugin.py

@@ -349,7 +349,7 @@ class Monitor:
     _INACTIVE_SLEEP_MS = 100
     _MIN_HOST_CHECK_TIMEOUT_MS = 3000
     _MONITORING_PROPERTY_PREFIX = "monitoring-"
-    _QUERY: str = "SELECT 1"
+    _QUERY = "SELECT 1"
 
     def __init__(
             self,
@@ -561,7 +561,7 @@ def _is_host_available(self, conn: Connection, timeout_sec: float) -> bool:
     def _execute_conn_check(self, conn: Connection, timeout_sec: float):
         driver_dialect = self._plugin_service.driver_dialect
         with conn.cursor() as cursor:
-            query = _query
+            query = Monitor._QUERY
             driver_dialect.execute("Cursor.execute", lambda: cursor.execute(query), query, exec_timeout=timeout_sec)
             cursor.fetchone()