diff --git a/src/backend/base/langflow/services/telemetry/service.py b/src/backend/base/langflow/services/telemetry/service.py
index bb8d27e45c75..908b5009452c 100644
--- a/src/backend/base/langflow/services/telemetry/service.py
+++ b/src/backend/base/langflow/services/telemetry/service.py
@@ -3,7 +3,6 @@
 import asyncio
 import os
 import platform
-import sys
 from datetime import datetime, timezone
 from typing import TYPE_CHECKING
 
@@ -135,15 +134,11 @@ async def flush(self) -> None:
 
     async def _cancel_task(self, task: asyncio.Task, cancel_msg: str) -> None:
         task.cancel(cancel_msg)
-        try:
-            await task
-        except asyncio.CancelledError:
-            current_task = asyncio.current_task()
-            if sys.version_info >= (3, 11):
-                if current_task and current_task.cancelling() > 0:
-                    raise
-            elif current_task and hasattr(current_task, "_must_cancel") and current_task._must_cancel:
-                raise
+        await asyncio.wait([task])
+        if not task.cancelled():
+            exc = task.exception()
+            if exc is not None:
+                raise exc
 
     async def stop(self) -> None:
         if self.do_not_track or self._stopping: