diff --git a/tap_postgres/client.py b/tap_postgres/client.py
index 0c6d1483..0ad4fef7 100644
--- a/tap_postgres/client.py
+++ b/tap_postgres/client.py
@@ -282,7 +282,7 @@ def get_records(self, context: Optional[dict]) -> Iterable[Dict[str, Any]]:
                 query = query.filter(replication_key_col >= start_val)
 
         with self.connector._connect() as con:
-            for row in con.execute(query):
+            for row in con.execute(query).mappings():
                 yield dict(row)