From 9b1f53854390689166c9ca94b6121a3f1379f0d5 Mon Sep 17 00:00:00 2001 From: Sophia Tevosyan Date: Mon, 15 Dec 2025 10:53:51 -0800 Subject: [PATCH] first commit --- .../com/microsoft/durabletask/DurableTaskGrpcClient.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/client/src/main/java/com/microsoft/durabletask/DurableTaskGrpcClient.java b/client/src/main/java/com/microsoft/durabletask/DurableTaskGrpcClient.java index 0b945cea..52d072b8 100644 --- a/client/src/main/java/com/microsoft/durabletask/DurableTaskGrpcClient.java +++ b/client/src/main/java/com/microsoft/durabletask/DurableTaskGrpcClient.java @@ -71,11 +71,16 @@ public final class DurableTaskGrpcClient extends DurableTaskClient { public void close() { if (this.managedSidecarChannel != null) { try { - this.managedSidecarChannel.shutdown().awaitTermination(5, TimeUnit.SECONDS); + if (!this.managedSidecarChannel.shutdown().awaitTermination(5, TimeUnit.SECONDS)) + { + this.managedSidecarChannel.shutdownNow(); + } } catch (InterruptedException e) { // Best effort. Also note that AutoClose documentation recommends NOT having // close() methods throw InterruptedException: // https://docs.oracle.com/javase/7/docs/api/java/lang/AutoCloseable.html + this.managedSidecarChannel.shutdownNow(); + Thread.currentThread().interrupt(); } } }