Skip to content

Commit e0ef6fb

Browse files
authored
Fix workflow client close (#891)
* feat: ensure taskhubgrpcclient expose .close() method for clients to pass down a close call to durabletask Signed-off-by: Casper Nielsen <casper@diagrid.io> * chore(deps): bump durabletask-dapr to 0.2.0a15 Signed-off-by: Casper Nielsen <casper@diagrid.io> --------- Signed-off-by: Casper Nielsen <casper@diagrid.io>
1 parent 7c43a26 commit e0ef6fb

3 files changed

Lines changed: 6 additions & 2 deletions

File tree

dev-requirements.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ Flask>=1.1
1414
# needed for auto fix
1515
ruff===0.14.1
1616
# needed for dapr-ext-workflow
17-
durabletask-dapr >= 0.2.0a9
17+
durabletask-dapr >= 0.2.0a15
1818
# needed for .env file loading in examples
1919
python-dotenv>=1.0.0
2020
# needed for enhanced schema generation from function features

ext/dapr-ext-workflow/dapr/ext/workflow/dapr_workflow_client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -277,3 +277,7 @@ def purge_workflow(self, instance_id: str, recursive: bool = True):
277277
recursive: The optional flag to also purge data from all child workflows.
278278
"""
279279
return self.__obj.purge_orchestration(instance_id, recursive)
280+
281+
def close(self):
282+
"""Closes the gRPC connection used by the client."""
283+
return self.__obj.close()

ext/dapr-ext-workflow/setup.cfg

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ packages = find_namespace:
2525
include_package_data = True
2626
install_requires =
2727
dapr >= 1.17.0rc1
28-
durabletask-dapr >= 0.2.0a12
28+
durabletask-dapr >= 0.2.0a15
2929

3030
[options.packages.find]
3131
include =

0 commit comments

Comments
 (0)