diff --git a/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ExecutionServer.java b/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ExecutionServer.java index 8a16a4260ad8c6..fdac75953fc327 100644 --- a/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ExecutionServer.java +++ b/src/tools/remote/src/main/java/com/google/devtools/build/remote/worker/ExecutionServer.java @@ -217,11 +217,7 @@ public void execute(ExecuteRequest request, StreamObserver responseOb executorService.submit(() -> execute(context, request, opName)); operationsCache.put(opName, future); ((ServerCallStreamObserver) responseObserver) - .setOnCancelHandler( - () -> { - future.cancel(false); - operationsCache.remove(opName); - }); + .setOnCancelHandler(() -> operationsCache.remove(opName)); // Send the first operation. responseObserver.onNext(Operation.newBuilder().setName(opName).build()); // When the operation completes, send the result.