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

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, since asyncio.CancelledError can crossing
async-sync boundaries, such as `run_coroutine_threadsafe().result()` or a sync
helper function that re-raises cancellation that was previously
suppressed/deferred.

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