diff --git a/posthog/temporal/batch_exports/snowflake_batch_export.py b/posthog/temporal/batch_exports/snowflake_batch_export.py index efd10468fc7..d3f7b1e3a02 100644 --- a/posthog/temporal/batch_exports/snowflake_batch_export.py +++ b/posthog/temporal/batch_exports/snowflake_batch_export.py @@ -12,7 +12,7 @@ import pyarrow as pa import snowflake.connector from django.conf import settings from snowflake.connector.connection import SnowflakeConnection -from snowflake.connector.errors import OperationalError +from snowflake.connector.errors import OperationalError, InterfaceError from temporalio import activity, workflow from temporalio.common import RetryPolicy @@ -206,6 +206,9 @@ class SnowflakeClient: else: raise SnowflakeConnectionError(f"Could not connect to Snowflake - {err.errno}: {err.msg}") from err + except InterfaceError as err: + raise SnowflakeConnectionError(f"Could not connect to Snowflake - {err.errno}: {err.msg}") from err + self._connection = connection await self.use_namespace()