diff --git a/java/runtime/src/main/java/org/ray/runtime/raylet/MockRayletClient.java b/java/runtime/src/main/java/org/ray/runtime/raylet/MockRayletClient.java index e39fbe969..389f43c44 100644 --- a/java/runtime/src/main/java/org/ray/runtime/raylet/MockRayletClient.java +++ b/java/runtime/src/main/java/org/ray/runtime/raylet/MockRayletClient.java @@ -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 WaitResult wait(List> waitFor, int numReturns, int timeoutMs) { - throw new RuntimeException("Not implemented here."); + return new WaitResult( + waitFor, + ImmutableList.of() + ); } @Override