fix(observe): Handle asyncio.CancelledError in exception blocks (#1566)

Fixes langfuse/langfuse#12650

This catches and records the async task being cancelled—either directly or
because it timed out—which will raise an asyncio.CancelledError to stop
execution.

Also fix sync wrappers as well. Note that asyncio.CancelledError can cross
async-sync boundaries, such as `run_coroutine_threadsafe().result()` or a sync
helper function that re-raises cancellation that was previously
suppressed/deferred.

Co-authored-by: Hassieb Pakzad <68423100+hassiebp@users.noreply.github.com>

Author: jinohkang-theori

langfuse/_client/observe.py

@@ -327,7 +327,7 @@ async def async_wrapper(*args: Tuple[Any], **kwargs: Dict[str, Any]) -> Any:
                             langfuse_span_or_generation.update(output=result)
 
                         return result
-                    except Exception as e:
+                    except (Exception, asyncio.CancelledError) as e:
                         langfuse_span_or_generation.update(
                             level="ERROR", status_message=str(e) or type(e).__name__
                         )
@@ -445,7 +445,7 @@ def sync_wrapper(*args: Any, **kwargs: Any) -> Any:
                             langfuse_span_or_generation.update(output=result)
 
                         return result
-                    except Exception as e:
+                    except (Exception, asyncio.CancelledError) as e:
                         langfuse_span_or_generation.update(
                             level="ERROR", status_message=str(e) or type(e).__name__
                         )
@@ -586,7 +586,7 @@ def __next__(self) -> Any:
 
             raise  # Re-raise StopIteration
 
-        except Exception as e:
+        except (Exception, asyncio.CancelledError) as e:
             self.span.update(
                 level="ERROR", status_message=str(e) or type(e).__name__
             ).end()
@@ -653,7 +653,7 @@ async def __anext__(self) -> Any:
             self.span.update(output=output).end()
 
             raise  # Re-raise StopAsyncIteration
-        except Exception as e:
+        except (Exception, asyncio.CancelledError) as e:
             self.span.update(
                 level="ERROR", status_message=str(e) or type(e).__name__
             ).end()