Merge branch 'master' into master

libs/core/tests/unit_tests/runnables/test_runnable_events_v2.py

@@ -2,6 +2,7 @@
 import asyncio
 import sys
 import uuid
+from functools import partial
 from itertools import cycle
 from typing import (
     Any,
@@ -346,6 +347,22 @@ def reverse(s: str) -> str:
     ]
 
 
+async def test_event_stream_exception() -> None:
+    def step(name: str, err: Optional[str], val: str) -> str:
+        if err:
+            raise ValueError(err)
+        return val + name[-1]
+
+    chain = (
+        RunnableLambda(partial(step, "step1", None))
+        | RunnableLambda(partial(step, "step2", "ERR"))
+        | RunnableLambda(partial(step, "step3", None))
+    )
+
+    with pytest.raises(ValueError, match="ERR"):
+        await _collect_events(chain.astream_events("X", version="v2"))
+
+
 async def test_event_stream_with_triple_lambda_test_filtering() -> None:
     """Test filtering based on tags / names"""