chore(data-warehouse): make sure exception is passed through at workf…

…low step (#23409)
PostHog · Jul 2, 2024 · 0c176a5 · 0c176a5
1 parent 6b31296
commit 0c176a5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/posthog/temporal/data_imports/pipelines/pipeline.py b/posthog/temporal/data_imports/pipelines/pipeline.py
@@ -150,6 +150,6 @@ def _run(self) -> dict[str, int]:
     async def run(self) -> dict[str, int]:
         try:
             return await asyncio.to_thread(self._run)
-        except PipelineStepFailed:
-            self.logger.exception(f"Data import failed for endpoint")
+        except PipelineStepFailed as e:
+            self.logger.exception(f"Data import failed for endpoint with exception {e}", exc_info=e)
             raise