diff --git a/tap_snowflake/client.py b/tap_snowflake/client.py
index 7838584..4e39c2d 100644
--- a/tap_snowflake/client.py
+++ b/tap_snowflake/client.py
@@ -524,5 +524,5 @@ def get_records(self, context: types.Context | None) -> Iterable[dict[str, Any]]
         if self.ABORT_AT_RECORD_COUNT is not None:
             query = query.limit(self.ABORT_AT_RECORD_COUNT)
 
-        for record in self.connector.execute(query):  # type: ignore[attr-defined]
-            yield record._asdict()
+        for record in self.connector.execute(query).mappings(): # type: ignore[attr-defined]
+            yield dict(record)