[WORKFLOW SDK FEATURE REQUEST] Use `grpc.aio` in the durabletask worker
まだ誰も着手していません。
評価
- 難易度
- 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時間
- マージ済み PR（30日）
- 5
コントリビューションガイド
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- 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 ·
dapr/python-sdk の issue をすべて見る
似ている 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 件 ·