Fix

2026-08-21 15:12:26 +02:00 · 2025-05-23 15:06:18 -07:00
parent 913b8d5e95
commit bece43dc67
1 changed files with 3 additions and 3 deletions
@@ -8786,12 +8786,12 @@ def test_imp_exception(

    @entrypoint(checkpointer=sync_checkpointer)
    def my_workflow(number: int):
-        my_task(number)
+        my_task(number).result()
        try:
-            task_with_exception(number)
+            task_with_exception(number).result()
        except Exception as e:
            print(f"Exception caught: {e}")
-        my_task(number)
+        my_task(number).result()
        return "done"

    thread1 = {"configurable": {"thread_id": "1"}}