Handle snowflake table already exists

Author: treysp

sqlmesh/core/engine_adapter/snowflake.py

@@ -700,9 +700,13 @@ def _record_execution_stats(
                 #     - [^"] matches any single character except a double-quote
                 #     - | or
                 #     - "" matches two sequential double-quotes
-                is_ctas = re.match(
+                is_created = re.match(
                     r'Table ([a-zA-Z0-9_$]+|"(?:[^"]|"")+") successfully created\.', results_str
                 )
-                if is_ctas:
+                is_already_exists = re.match(
+                    r'([a-zA-Z0-9_$]+|"(?:[^"]|"")+") already exists, statement succeeded\.',
+                    results_str,
+                )
+                if is_created or is_already_exists:
                     return
         QueryExecutionTracker.record_execution(sql, rowcount, bytes_processed)

tests/core/engine_adapter/integration/test_integration.py

@@ -2418,7 +2418,9 @@ def capture_execution_stats(
     assert len(physical_layer_results.tables) == len(physical_layer_results.non_temp_tables) == 3
 
     if ctx.engine_adapter.SUPPORTS_QUERY_EXECUTION_TRACKING:
-        assert actual_execution_stats["seed_model"].total_rows_processed == 7
+        assert actual_execution_stats["seed_model"].total_rows_processed == (
+            None if ctx.mark.startswith("snowflake") else 7
+        )
         assert actual_execution_stats["incremental_model"].total_rows_processed == 7
         # snowflake doesn't track rows for CTAS
         assert actual_execution_stats["full_model"].total_rows_processed == (