[WORKFLOW SDK FEATURE REQUEST] Use `grpc.aio` in the durabletask worker
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 4/5
- Tiempo estimado
- 3-5 días
- Aptitud para principiantes
- 52/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Bastante claro
- Estado de actividad
- Tranquilo
- Stack tecnológico
- grpc, python
- Área
- backend, distributed-systems
Línea de trabajo
Empieza por localizar TaskHubGrpcWorker y el ciclo de vida de WorkflowRuntime.start()/shutdown(), y luego sigue el uso existente del hilo StreamReader, la cola y grpc.aio. El objetivo se cumple cuando el worker consume el stream de forma asíncrona sin cambiar la API pública, se vuelve a conectar tras desconexiones y errores transitorios, conserva el comportamiento de inicio y apagado y no deja recursos sin liberar.
Escrito por el modelo de indexación a partir del texto del issue.
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
- Lenguaje dominante
- Python
- Estrellas
- 272
- Forks
- 152
- Merge medio
- 3 d 21 h
- PR fusionados (30 d)
- 5
Guía de contribución
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de dapr/python-sdk
-
dapr-ext-workflow good first issue kind/enhancement P2
Dificultad 2/5 1-2 días Aptitud para principiantes 72/100
dapr/python-sdk#853 · 4 comentarios ·
-
kind/bug
Dificultad 4/5 3-5 días Aptitud para principiantes 45/100
dapr/python-sdk#1230 ·
-
feature-request
Dificultad 3/5 1-2 días Aptitud para principiantes 76/100
dapr/python-sdk#1214 · 1 asignado ·
-
dapr-ext-workflow kind/enhancement
Dificultad 3/5 1-2 días Aptitud para principiantes 78/100
dapr/python-sdk#1213 ·
-
Dificultad 3/5 1-2 días Aptitud para principiantes 76/100
dapr/python-sdk#1200 ·
Todos los issues de dapr/python-sdk
Issues similares
-
[Bug] reef-hermes tells me to resume with hermes --resume, which does not work from my shell Abiertoarea: harness bug status: needs-triage
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
Human-Agent-Society/reef#625 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
-
Dificultad 1/5 Menos de una hora Aptitud para principiantes 80/100
learningequality/kolibri#15351 · 2 comentarios ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
-
Name consistency Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
eellak/triplestore#65 · 1 comentario ·