Skip to content

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

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

No one assigned

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions