[WORKFLOW SDK FEATURE REQUEST] Use `grpc.aio` in the durabletask worker
Đang mở
dapr-ext-workflow
kind/enhancement
- Ngôn ngữ chính
- Python
- Star
- 272
- Fork
- 152
- Chỉ số merge pull request
- Không có pull request nào được merge trong 30 ngày
Mô tả
`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
Hướng dẫn đóng góp
Đánh giá
Issue này chưa được đánh giá.