Send task error instead of raw exception for signal (#4150)

This commit is contained in:
Eric Liang
2019-03-01 23:59:29 -08:00
committed by Robert Nishihara
parent c4aa90314d
commit 9950f63e8c
+1 -1
View File
@@ -901,7 +901,7 @@ class Worker(object):
if not self.actor_id.is_nil() and function_name == "__init__":
self.mark_actor_init_failed(error)
# Send signal with the error.
ray_signal.send(ray_signal.ErrorSignal(error))
ray_signal.send(ray_signal.ErrorSignal(str(failure_object)))
def _wait_for_and_process_task(self, task):
"""Wait for a task to be ready and process the task.