Ruiyang Wang

Results 78 comments of Ruiyang Wang

[core] Add convenience method `RAY_LOG(INFO).WithField(job_id)`.

Trying an approach with traits

[core] Add 1s timeout in RPC to CoreWorkerService.NumPendingTasks in GcsJobManager::HandleGetAllJobInfo

Note: we probably also want to add timeouts to all other CoreWorkerInterface APIs, later some day.

[core] Add 1s timeout in RPC to CoreWorkerService.NumPendingTasks in GcsJobManager::HandleGetAllJobInfo

@shomilj can you take a look approve this PR? it's adding a 1s timeout when GCS asks each driver core worker about is_running_tasks. If it timed out, GCS returns (not...

[core] Add 1s timeout in RPC to CoreWorkerService.NumPendingTasks in GcsJobManager::HandleGetAllJobInfo

> If it's unset, what will http server returns to the caller? it returns a json that simply does not have such field. See the test. https://github.com/ray-project/ray/blob/4a7c107e5fa1c01863348ac92dbadf3a13ad88cb/python/ray/tests/test_state_api.py#L3653 > Also can...

[core] Add 1s timeout in RPC to CoreWorkerService.NumPendingTasks in GcsJobManager::HandleGetAllJobInfo

can merge?

[core] `ray.get` on a mixed list of dead and alive (but hanging) tasks does not immediately raise `RayActorError`

Expected behavior: the crashed actor's any pending tasks raise ActorDiedError on `ray.get(obj)`, or `ray.get([obj, other_objs])`. should not hang

Split python/ray/tests/test_actor_retry over two files

I'm ok with this.

[core] Add from_binary and from_hex to all IDs.

@jjyao good to review

[core] Add from_binary and from_hex to all IDs.

2 sizes is modeled after TaskID who has both. Do you think we need to remove it?

[core] Add from_binary and from_hex to all IDs.

done. now we only have classmethod size. Also changed all FromHex arg to hex_str.