diff --git a/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java b/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java index f5d47f3e7..7caadaad4 100644 --- a/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java +++ b/sdk-workflows/src/main/java/io/dapr/workflows/runtime/WorkflowRuntime.java @@ -16,6 +16,7 @@ import io.dapr.durabletask.DurableTaskGrpcWorker; import io.grpc.ManagedChannel; +import java.time.Duration; import java.util.concurrent.ExecutorService; import java.util.concurrent.TimeUnit; @@ -73,6 +74,14 @@ public void close() { this.worker.close(); } + /** + * Immediately shuts down all resources associated with this instance. + */ + public void closeNow() { + this.executorService.shutdownNow(); + this.managedChannel.shutdownNow(); + } + private void closeSideCarChannel() { this.managedChannel.shutdown();