use mappings filter

MeltanoLabs · Sep 7, 2024 · c92b561 · c92b561
1 parent 7cbd51c
commit c92b561
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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)