diff --git a/posthog/temporal/workflows/postgres_batch_export.py b/posthog/temporal/workflows/postgres_batch_export.py index a396f361b77c5..fa83d31404e8e 100644 --- a/posthog/temporal/workflows/postgres_batch_export.py +++ b/posthog/temporal/workflows/postgres_batch_export.py @@ -245,7 +245,11 @@ async def run(self, inputs: PostgresBatchExportInputs): initial_interval=dt.timedelta(seconds=10), maximum_interval=dt.timedelta(seconds=120), maximum_attempts=10, - non_retryable_error_types=[], + non_retryable_error_types=[ + # Raised on errors that are related to database operation. + # For example: unexpected disconnect, database or other object not found. + "OperationalError" + ], ), )