diff --git a/core/wren/src/wren/connector/redshift.py b/core/wren/src/wren/connector/redshift.py
index 918c8a2244..4ac76b4940 100644
--- a/core/wren/src/wren/connector/redshift.py
+++ b/core/wren/src/wren/connector/redshift.py
@@ -52,7 +52,7 @@ def query(self, sql: str, limit: int | None = None) -> pa.Table:
         else:
             # Unlimited path also rejects trailing ``;`` for single statements
             # depending on driver/session settings — strip for consistency.
-            sql = _strip_trailing_semicolon(sql)
+            sql = strip_trailing_semicolon(sql)
         with closing(self.connection.cursor()) as cursor:
             cursor.execute(sql)
             cols = [desc[0] for desc in cursor.description]