dapr / dapr/python-sdk

[WORKFLOW SDK FEATURE REQUEST] Use `grpc.aio` in the durabletask worker

Ouverte
#1,089 3 commentaires 0 réactions 0 personnes assignées Voir sur GitHub
dapr-ext-workflow kind/enhancement
Langage dominant
Python
Étoiles
272
Forks
152
Métriques de merge des PR
Aucune PR mergée en 30 j

Description

`TaskHubGrpcWorker` consumes the sidecar stream on a dedicated `StreamReader` thread and pushes things to the event loop through a queue. We already have grpc.aio in the SDK, we can consume it asynchronously and remove the thread and the queue.

This should not change the public API.

----

Acceptance criteria:

- [ ] The worker consumes the stream asynchronously
- [ ] `WorkflowRuntime.start()` / `.shutdown()` still works
- [ ] Reconnect on stream drop and on transient errors still works
- [ ] No leaked resources on shutdown

Guide de contribution

Ouvrir le guide de contribution

Évaluation

Cette issue n'a pas encore été évaluée.

Recevez les nouvelles issues par e-mail

Un résumé court des issues GitHub adaptées aux débutants.