[ray_client]: fix exceptions raised while executing on the server on behalf of the client (#13424)

This commit is contained in:
Barak Michener
2021-01-14 08:38:01 -08:00
committed by GitHub
parent 2f7ba25efb
commit 9c6d892eec
2 changed files with 6 additions and 2 deletions
+5
View File
@@ -855,6 +855,11 @@ def test_inherit_actor_from_class(ray_start_regular_shared):
assert ray.get(actor.g.remote(5)) == 6
def test_get_non_existing_named_actor(ray_start_regular_shared):
with pytest.raises(ValueError):
_ = ray.get_actor("non_existing_actor")
@pytest.mark.skip(
"This test is just used to print the latency of creating 100 actors.")
def test_actor_creation_latency(ray_start_regular_shared):
+1 -2
View File
@@ -261,8 +261,7 @@ class RayletServicer(ray_client_pb2_grpc.RayletDriverServicer):
result.valid = True
return result
except Exception as e:
logger.error(f"Caught schedule exception {e}")
raise e
logger.debug(f"Caught schedule exception, returning: {e}")
return ray_client_pb2.ClientTaskTicket(
valid=False, error=cloudpickle.dumps(e))