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

Activity

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

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