From 0c4b9b1d6a7ca75b825b5438b1c1856d3521cd0d Mon Sep 17 00:00:00 2001 From: Casper Nielsen Date: Fri, 16 Jan 2026 11:41:18 +0100 Subject: [PATCH 1/2] feat: ensure taskhubgrpcclient expose .close() method for clients to pass down a close call to durabletask Signed-off-by: Casper Nielsen --- .../dapr/ext/workflow/dapr_workflow_client.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py b/ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py index 461bfd43a..36a731c47 100644 --- a/ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py +++ b/ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py @@ -277,3 +277,7 @@ def purge_workflow(self, instance_id: str, recursive: bool = True): recursive: The optional flag to also purge data from all child workflows. """ return self.__obj.purge_orchestration(instance_id, recursive) + + def close(self): + """Closes the gRPC connection used by the client.""" + return self.__obj.close() From c63141dafdedd27da49a68710d7293acc49963d3 Mon Sep 17 00:00:00 2001 From: Casper Nielsen Date: Fri, 16 Jan 2026 11:41:32 +0100 Subject: [PATCH 2/2] chore(deps): bump durabletask-dapr to 0.2.0a15 Signed-off-by: Casper Nielsen --- dev-requirements.txt | 2 +- ext/dapr-ext-workflow/setup.cfg | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/dev-requirements.txt b/dev-requirements.txt index 828ef8aa4..59bd44c84 100644 --- a/dev-requirements.txt +++ b/dev-requirements.txt @@ -14,7 +14,7 @@ Flask>=1.1 # needed for auto fix ruff===0.14.1 # needed for dapr-ext-workflow -durabletask-dapr >= 0.2.0a9 +durabletask-dapr >= 0.2.0a15 # needed for .env file loading in examples python-dotenv>=1.0.0 # needed for enhanced schema generation from function features diff --git a/ext/dapr-ext-workflow/setup.cfg b/ext/dapr-ext-workflow/setup.cfg index 18d342586..d46c11856 100644 --- a/ext/dapr-ext-workflow/setup.cfg +++ b/ext/dapr-ext-workflow/setup.cfg @@ -25,7 +25,7 @@ packages = find_namespace: include_package_data = True install_requires = dapr >= 1.17.0rc1 - durabletask-dapr >= 0.2.0a12 + durabletask-dapr >= 0.2.0a15 [options.packages.find] include =