Skip to content

[WORKFLOW SDK FEATURE REQUEST] Use grpc.aio in the durabletask worker #1089

@seherv

Description

@seherv

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

Metadata

Metadata

Assignees

Type

No type
No fields configured for issues without a type.

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions