mirror of
https://github.com/wassname/ray.git
synced 2026-06-28 12:10:40 +08:00
[Core] Fix a detached actor bug fix when GCS actor management is off. (#8843)
This commit is contained in:
@@ -712,6 +712,8 @@ def test_detached_actor_cleanup(ray_start_regular):
|
||||
detached_actor = DetachedActor.options(name=actor_name).remote()
|
||||
# Wait for detached actor creation.
|
||||
assert ray.get(detached_actor.ping.remote()) == "pong"
|
||||
del detached_actor
|
||||
detached_actor = ray.get_actor(dup_actor_name)
|
||||
ray.kill(detached_actor)
|
||||
# Wait until actor dies.
|
||||
actor_status = ray.actors(actor_id=detached_actor._actor_id.hex())
|
||||
|
||||
@@ -77,7 +77,7 @@ def _register_actor(name, actor_handle):
|
||||
raise ValueError("An actor with name={} already exists".format(name))
|
||||
|
||||
# Add the actor to Redis if it does not already exist.
|
||||
_internal_kv_put(actor_name, pickle.dumps(actor_handle))
|
||||
_internal_kv_put(actor_name, pickle.dumps(actor_handle), overwrite=True)
|
||||
|
||||
|
||||
def register_actor(name, actor_handle):
|
||||
|
||||
Reference in New Issue
Block a user