ray/src/ray at 7abfbfd2f7c5878aaa7bc878b55ef00d31cf3ebc - ray

mirror of https://github.com/wassname/ray.git synced 2026-06-29 09:22:57 +08:00

Files

T

Stephanie Wang 4abafd7e62 Fix bug in ray.wait (#3445 )

ray.wait depends on callbacks from the GCS to decide when an object has appeared in the cluster. The raylet crashes if a callback is received for a wait request that has already completed, but this actually can happen, depending on the order of calls. More precisely:

1. Objects A and B are put in the cluster.
2. Client calls ray.wait([A, B], num_returns=1).
3. Client subscribes to locations for A and B. Locations are cached for both, so callbacks are posted for each.
4. Callback for A fires. The wait completes and the request is removed.
5. Callback for B fires. The wait request no longer exists and raylet crashes.

2018-12-01 19:40:33 -08:00

common

Remove uses of std::list::size (#3358 )

2018-11-20 14:47:55 -08:00

gcs

Fix failure handling for actor death (#3359 )

2018-11-21 12:26:22 -08:00

object_manager

Fix bug in ray.wait (#3445 )

2018-12-01 19:40:33 -08:00

raylet

Fault tolerance for actor creation (#3422 )