[WORKFLOW SDK FEATURE REQUEST] Use `grpc.aio` in the durabletask worker
还没有人认领这个 Issue。
评估
- 难度
- 4/5
- 预计耗时
- 3-5 天
- 新手友好度
- 52/100
- Issue 类型
- 功能
- 描述清晰度
- 基本清楚
- 活跃度
- 冷清
- 技术栈
- grpc, python
调研方向
首先定位 TaskHubGrpcWorker 和 WorkflowRuntime.start()/shutdown() 的生命周期，然后追踪现有的 StreamReader 线程、队列和 grpc.aio 的使用情况。完成标准是：worker 在不更改公共 API 的情况下异步消费流，在连接断开和发生暂时性错误后重新连接，保留启动和关闭行为，并且不泄漏资源。
由索引模型根据 Issue 内容生成。
描述
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
- 主要语言
- Python
- 星标
- 272
- 派生
- 152
- 平均合并
- 3 天 21 小时
- 30 天内合并 PR
- 5
贡献指南
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
dapr/python-sdk 的其他 Issue
-
dapr-ext-workflow good first issue kind/enhancement P2
难度 2/5 1-2 天 新手友好度 72/100
dapr/python-sdk#853 · 4 条评论 ·
-
kind/bug
难度 4/5 3-5 天 新手友好度 45/100
dapr/python-sdk#1230 ·
-
feature-request
难度 3/5 1-2 天 新手友好度 76/100
dapr/python-sdk#1214 · 已指派 1 人 ·
-
dapr-ext-workflow kind/enhancement
难度 3/5 1-2 天 新手友好度 78/100
dapr/python-sdk#1213 ·
-
难度 3/5 1-2 天 新手友好度 76/100
dapr/python-sdk#1200 ·
相似的 Issue
-
area: harness bug status: needs-triage
难度 2/5 1-3 小时 新手友好度 75/100
Human-Agent-Society/reef#625 ·
-
难度 2/5 1-3 小时 新手友好度 70/100
-
难度 1/5 1 小时以内 新手友好度 80/100
learningequality/kolibri#15351 · 2 条评论 ·
-
难度 2/5 1-3 小时 新手友好度 75/100
-
Name consistency 未关闭
难度 2/5 1-3 小时 新手友好度 75/100
eellak/triplestore#65 · 1 条评论 ·