diff --git a/rattail_corepos/datasync/corepos.py b/rattail_corepos/datasync/corepos.py
index ed6d26f..685a2ab 100644
--- a/rattail_corepos/datasync/corepos.py
+++ b/rattail_corepos/datasync/corepos.py
@@ -54,7 +54,7 @@ class CoreOfficeOpWatcher(DataSyncWatcher):
 
     def get_changes(self, lastrun):
         session = CoreSession()
-        result = session.execute(sa.sql.select([self.corepos_changes]))
+        result = session.execute(self.corepos_changes.select())
         changes = result.fetchall()
         session.close()
         if changes: