wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-06-28 19:33:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Java] Implement missing methods in MockRayletClient (#2954)

Browse Source 
Previous changes broke single-process mode in raylet. This PR fixes the hello-world example work in single-process mode. Follow-up diffs will completely fix single-process mode and add tests.
This commit is contained in:
Hao Chen
2018-09-26 00:57:32 +08:00
committed by Robert Nishihara
parent 39b4a89fde
commit 3cccb49191
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
java/runtime/src/main/java/org/ray/runtime/raylet/MockRayletClient.java
+6 -2
View File
@@ -1,5 +1,6 @@
package org.ray.runtime.raylet;
import com.google.common.collect.ImmutableList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
@@ -82,12 +83,15 @@ public class MockRayletClient implements RayletClient {
@Override
public UniqueId generateTaskId(UniqueId driverId, UniqueId parentTaskId, int taskIndex) {
throw new RuntimeException("Not implemented here.");
return UniqueId.randomId();
}
@Override
public <T> WaitResult<T> wait(List<RayObject<T>> waitFor, int numReturns, int timeoutMs) {
throw new RuntimeException("Not implemented here.");
return new WaitResult<T>(
waitFor,
ImmutableList.of()
);
}
@Override