fix: commit transaction from pandas read sql query (#1492)

Author: eakmanrq

sqlmesh/core/engine_adapter/postgres.py

@@ -3,14 +3,16 @@
 import logging
 import typing as t
 
+from sqlglot import exp
+
 from sqlmesh.core.engine_adapter.base_postgres import BasePostgresEngineAdapter
 from sqlmesh.core.engine_adapter.mixins import (
     LogicalReplaceQueryMixin,
     PandasNativeFetchDFSupportMixin,
 )
 
 if t.TYPE_CHECKING:
-    pass
+    from sqlmesh.core.engine_adapter._typing import DF
 
 logger = logging.getLogger(__name__)
 
@@ -20,3 +22,16 @@ class PostgresEngineAdapter(
 ):
     DIALECT = "postgres"
     SUPPORTS_INDEXES = True
+
+    def _fetch_native_df(
+        self, query: t.Union[exp.Expression, str], quote_identifiers: bool = False
+    ) -> DF:
+        """
+        `read_sql_query` when using psycopg will result on a hanging transaction that must be committed
+
+        https://github.com/pandas-dev/pandas/pull/42277
+        """
+        df = super()._fetch_native_df(query, quote_identifiers)
+        if not self._connection_pool.is_transaction_active:
+            self._connection_pool.commit()
+        return df