Fix snowflake

Author: erindru

sqlmesh/core/engine_adapter/snowflake.py

@@ -451,6 +451,10 @@ def _get_data_objects(
         if object_names:
             query = query.where(exp.column("TABLE_NAME").isin(*object_names))
 
+        # exclude SNOWPARK_TEMP_TABLE tables that are managed by the Snowpark library and are an implementation
+        # detail of dealing with DataFrame's
+        query = query.where(exp.column("TABLE_NAME").like("SNOWPARK_TEMP_TABLE%").not_())
+
         df = self.fetchdf(query, quote_identifiers=True)
         if df.empty:
             return []

tests/core/engine_adapter/integration/__init__.py

@@ -713,6 +713,10 @@ def cleanup(self, ctx: t.Optional[Context] = None):
                 schema_name=schema_name, ignore_if_not_exists=True, cascade=True
             )
 
+        if snowpark := self.engine_adapter.snowpark:
+            # ensure that the next test gets a fresh Snowpark session
+            snowpark.close()
+
     def upsert_sql_model(self, model_definition: str) -> t.Tuple[Context, SqlModel]:
         if not self._context:
             self._context = self.create_context()