wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-28 14:31:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Core] Async API should raise on all RayError (#12043)

Browse Source 
Before this PR we are raising just RayTaskError, this means errors
like RayActorError(Actor Died) won't be propogated and thrown at
`await object_ref`. This PR fixes that.
This commit is contained in:
Simon Mo
2020-11-17 17:20:30 -08:00
committed by GitHub
parent e8c018e8fc
commit c476037c97
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/_raylet.pyx
+1 -1
View File
@@ -1524,7 +1524,7 @@ cdef void async_set_result(shared_ptr[CRayObject] obj,
cpython.Py_DECREF(py_future)
return
if isinstance(result, RayTaskError):
if isinstance(result, RayError):
ray.worker.last_task_error_raise_time = time.time()
py_future.set_exception(result.as_instanceof_cause())
else: