diff --git a/csp/adapters/db.py b/csp/adapters/db.py
index 1aba1240..8316c1a6 100644
--- a/csp/adapters/db.py
+++ b/csp/adapters/db.py
@@ -351,10 +351,7 @@ def build_query(self, starttime, endtime):
         elif self._rep._use_raw_user_query:
             return db.text(self._rep._query)
         else:  # self._rep._query
-            if _SQLALCHEMY_2:
-                from_obj = db.text(f"({self._rep._query})")
-            else:
-                from_obj = db.text(f"({self._rep._query}) AS user_query")
+            from_obj = db.text(f"({self._rep._query}) AS user_query")
 
             time_columns = self._rep._time_accessor.get_time_columns(self._rep._connection)
             if time_columns: