[WORKFLOW SDK FEATURE REQUEST] Use `grpc.aio` in the durabletask worker
Les mainteneurs répondent en général sous 7 jours
@seherv y travaille déjà.
Depuis le 11/6/2026.
Évaluation
- Difficulté
- 4/5
- Temps estimé
- 3-5 jours
- Accessibilité débutants
- 52/100
- Type d'issue
- Fonctionnalité
- Clarté
- Plutôt claire
- Activité
- Calme
- Stack technique
- grpc, python
- Domaine
- backend, distributed-systems
Piste de recherche
Commencez par localiser TaskHubGrpcWorker et le cycle de vie de WorkflowRuntime.start()/shutdown(), puis suivez l’utilisation existante du thread StreamReader, de la file d’attente et de grpc.aio. Le travail est terminé lorsque le worker consomme le flux de manière asynchrone sans modifier l’API publique, se reconnecte après des déconnexions et des erreurs transitoires, préserve le comportement au démarrage et à l’arrêt, et ne fuit aucune ressource.
Rédigé par le modèle d'indexation à partir du texte de l'issue.
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
- Langage dominant
- Python
- Étoiles
- 274
- Forks
- 157
- Merge moyen
- 8 j 20 h
- PR mergées (30 j)
- 31
Préparer son environnement
Lance le conteneur de développement du projet dans votre navigateur, avec votre propre compte GitHub.
- Aucun Dockerfile ni fichier Docker Compose
- Propose un modèle de pull request
- Lire le guide de contribution
Par où commencer
- Lisez l'issue en entier, puis le guide de contribution du projet.
- Signalez en commentaire que vous la prenez — cela évite que deux personnes fassent le même travail.
- Forkez le dépôt et travaillez sur une branche.
- Ouvrez une pull request qui référence le numéro de l'issue.
Autres issues de dapr/python-sdk
-
Report the http(s):// gRPC endpoint deprecation as a DeprecationWarning, not a UserWarning on every clientPeut-être pris @kocaemre l’a pris il y a 1 jour. Ouvertegood first issue
Difficulté 2/5 1-3 heures Accessibilité débutants 85/100
dapr/python-sdk#1275 ·
Les mainteneurs répondent en général sous 7 jours
-
SDK Alignment of Workflow ExamplesPeut-être à nouveau libre Une pull request pour cette issue a été fermée sans être fusionnée. Ouvertedapr-ext-workflow good first issue kind/enhancement P2
Difficulté 2/5 1-2 jours Accessibilité débutants 72/100
dapr/python-sdk#853 · 4 commentaires ·
Les mainteneurs répondent en général sous 7 jours
-
DAPR_* environment variables are snapshotted at import time, so loading config after import silently dials localhostPeut-être pris @CasperGN l’a pris il y a 5 jours. Ouverte
Difficulté 3/5 1-2 jours Accessibilité débutants 45/100
dapr/python-sdk#1259 · 1 personne assignée ·
Les mainteneurs répondent en général sous 7 jours
-
[WORKFLOW SDK FEATURE REQUEST] Retry WaitForInstanceCompletion/Start on a server-sent CANCELLEDOuvertedapr-ext-workflow kind/enhancement
Difficulté 4/5 3-5 jours Accessibilité débutants 55/100
dapr/python-sdk#1246 ·
Les mainteneurs répondent en général sous 7 jours
-
[BUG] subscribe_with_handler stops silently: async task can die or be collected, sync retry path exits, handler errors reconnect the streamPeut-être pris @CasperGN l’a pris il y a 20 jours. Ouvertekind/bug
Difficulté 4/5 3-5 jours Accessibilité débutants 65/100
dapr/python-sdk#1233 ·
Les mainteneurs répondent en général sous 7 jours
Toutes les issues de dapr/python-sdk
Issues similaires
-
customer-reported question
Difficulté 2/5 1-3 heures Accessibilité débutants 62/100
Azure/azure-sdk-for-python#49548 · 1 commentaire · 1 réaction ·
Les mainteneurs répondent en général sous 1 jour
-
Difficulté 1/5 Moins d'une heure Accessibilité débutants 88/100
btclib-org/btclib-wallet#409 ·
Les mainteneurs répondent en général sous 1 jour
-
Phase 2 PSA Capability & Career Profile
Difficulté 2/5 1-3 heures Accessibilité débutants 62/100
bcgov/digital-journeys#2310 ·
-
bug good first issue
Difficulté 2/5 1-3 heures Accessibilité débutants 78/100
fastmachinelearning/hls4ml#1582 ·
Les mainteneurs répondent en général sous 3 jours
-
Sort modelsOuverteenhancement good first issue
Difficulté 2/5 1-3 heures Accessibilité débutants 62/100
Les mainteneurs répondent en général sous 1 jour