mirrors/posthog
0
0
Fork 0
mirror of https://github.com/PostHog/posthog.git synced 2024-11-21 13:39:22 +01:00
Code Issues Releases Activity

fix: Make snowflake interface error non-retryable (#26269)

Browse Source
This commit is contained in:
Tomás Farías Santana 2024-11-19 11:12:39 +01:00 committed by GitHub
parent 383df6685c
commit 6b4ab24350
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
posthog/temporal/batch_exports/snowflake_batch_export.py
View File

@ -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()