diff --git a/dev-requirements.txt b/dev-requirements.txt index 828ef8aa..59bd44c8 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/dapr/ext/workflow/dapr_workflow_client.py b/ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py index 461bfd43..36a731c4 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() diff --git a/ext/dapr-ext-workflow/setup.cfg b/ext/dapr-ext-workflow/setup.cfg index 18d34258..d46c1185 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 =