dapr / dapr/python-sdk

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

Abierto
#1,089 3 comentarios 0 reacciones 0 asignados Ver en GitHub
dapr-ext-workflow kind/enhancement
Lenguaje dominante
Python
Estrellas
272
Forks
152
Métricas de merge de PR
Sin PR fusionados en 30 d

Descripción

`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

Guía de contribución

Abrir la guía de contribución

Evaluación

Este issue todavía no se ha evaluado.

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.