fix: Raise non-retryable on warehouse suspended by monitor (#41821)

tomasfarias · web-flow · commit 59f07c98685e · 2025-11-20T14:08:46.000Z
diff --git a/products/batch_exports/backend/temporal/destinations/snowflake_batch_export.py b/products/batch_exports/backend/temporal/destinations/snowflake_batch_export.py
@@ -761,7 +761,7 @@ async def copy_loaded_files_to_snowflake_table(
         except snowflake.connector.errors.ProgrammingError as e:
             self.logger.exception(f"Error executing COPY INTO query: {e}")
 
-            if e.errno == 608:
+            if e.errno == 608 or e.errno == 90073:
                 err_msg = (
                     f"Failed to execute COPY INTO query after {max_attempts} attempts due to warehouse being suspended"
                 )

Original file line number	Diff line number	Diff line change
`@@ -761,7 +761,7 @@ async def copy_loaded_files_to_snowflake_table(`
`761`	`761`	`except snowflake.connector.errors.ProgrammingError as e:`
`762`	`762`	`self.logger.exception(f"Error executing COPY INTO query: {e}")`
`763`	`763`
`764`		`- if e.errno == 608:`
	`764`	`+ if e.errno == 608 or e.errno == 90073:`
`765`	`765`	`err_msg = (`
`766`	`766`	`f"Failed to execute COPY INTO query after {max_attempts} attempts due to warehouse being suspended"`
`767`	`767`	`)`