Fix asyncio re-entry error message (#8842)

2026-07-07 09:04:14 +08:00 · 2020-06-08 17:43:01 -07:00
parent 3b32cf14a7
commit 5e2bd6ecb9
2 changed files with 26 additions and 0 deletions
@@ -75,6 +75,11 @@ def get_async(object_id):
            # Result from direct call.
            assert isinstance(result, AsyncGetResponse), result
            if result.plasma_fallback_id is None:
+                # If this future has result set already, we just need to
+                # skip the set result/exception procedure.
+                if user_future.done():
+                    return
+
                if isinstance(result.result, ray.exceptions.RayTaskError):
                    ray.worker.last_task_error_raise_time = time.time()
                    user_future.set_exception(